Searched refs:availableToWrite (Results 1 – 7 of 7) sorted by relevance
378 size_t availableToWrite = mDataMQ->availableToWrite(); in OutWritePcmData() local379 if (availableToWrite) { in OutWritePcmData()380 if (availableToWrite > (bytes - totalWritten)) { in OutWritePcmData()381 availableToWrite = bytes - totalWritten; in OutWritePcmData()385 availableToWrite)) { in OutWritePcmData()389 totalWritten += availableToWrite; in OutWritePcmData()
78 size_t availableToWrite = mDataMQ->availableToWrite(); in doRead() local80 if (requestedToRead > availableToWrite) { in doRead()84 (int32_t)requestedToRead, (int32_t)availableToWrite); in doRead()85 requestedToRead = availableToWrite; in doRead()
825 const size_t availableToWrite = sink->availableToWrite(); in audio_config_compare() local827 if (rsxadev->routes[out->route_handle].input == NULL && availableToWrite < frames) { in audio_config_compare()830 size_t frames_to_flush_from_source = frames - availableToWrite; in audio_config_compare()
729 if (tryWriteFmq && mResultMetadataQueue->availableToWrite() > 0) { in invokeProcessCaptureResultCallback()739 mResultMetadataQueue->availableToWrite()); in invokeProcessCaptureResultCallback()
718 if (tryWriteFmq && mResultMetadataQueue->availableToWrite() > 0) { in invokeProcessCaptureResultCallback_3_4()
902 if (tryWriteFmq && mResultMetadataQueue->availableToWrite() > 0) { in invokeProcessCaptureResultCallback()
3920 resultQueue->availableToWrite() <= 0) { in TEST_F()4150 resultQueue->availableToWrite() <= 0) { in TEST_F()4354 if (!resultQueue->isValid() || resultQueue->availableToWrite() <= 0) { in TEST_F()4634 resultQueue->availableToWrite() <= 0) { in TEST_F()