| /hardware/interfaces/tv/tuner/aidl/default/ |
| D | Dvr.cpp | 241 int availableToRead = mDvrMQ->availableToRead(); in maySendIptvPlaybackStatusCallback() local
244 PlaybackStatus newStatus = checkPlaybackStatusChange(availableToWrite, availableToRead, in maySendIptvPlaybackStatusCallback()
260 int availableToRead = mDvrMQ->availableToRead(); in maySendPlaybackStatusCallback() local
264 checkPlaybackStatusChange(availableToWrite, availableToRead, in maySendPlaybackStatusCallback()
273 PlaybackStatus Dvr::checkPlaybackStatusChange(uint32_t availableToWrite, uint32_t availableToRead, in checkPlaybackStatusChange() argument
277 } else if (availableToRead > highThreshold) { in checkPlaybackStatusChange()
279 } else if (availableToRead < lowThreshold) { in checkPlaybackStatusChange()
281 } else if (availableToRead == 0) { in checkPlaybackStatusChange()
289 size_t size = mDvrMQ->availableToRead(); in readPlaybackFMQ()
316 int size = mDvrMQ->availableToRead(); in processEsDataOnPlayback()
[all …]
|
| D | Dvr.h | 121 PlaybackStatus checkPlaybackStatusChange(uint32_t availableToWrite, uint32_t availableToRead,
123 RecordStatus checkRecordStatusChange(uint32_t availableToWrite, uint32_t availableToRead,
|
| D | Filter.cpp | 390 int size = mFilterMQ->availableToRead(); in flush()
689 int availableToRead = mFilterMQ->availableToRead(); in maySendFilterStatusCallback() local
694 availableToWrite, availableToRead, ceil(fmqSize * 0.75), ceil(fmqSize * 0.25)); in maySendFilterStatusCallback()
702 uint32_t availableToRead, uint32_t highThreshold, in checkFilterStatusChange() argument
706 } else if (availableToRead > highThreshold) { in checkFilterStatusChange()
708 } else if (availableToRead == 0) { in checkFilterStatusChange()
710 } else if (availableToRead < lowThreshold) { in checkFilterStatusChange()
|
| D | Filter.h | 216 DemuxFilterStatus checkFilterStatusChange(uint32_t availableToWrite, uint32_t availableToRead,
|
| /hardware/interfaces/tv/tuner/1.0/default/ |
| D | Dvr.cpp | 218 int availableToRead = mDvrMQ->availableToRead(); in maySendPlaybackStatusCallback() local
221 PlaybackStatus newStatus = checkPlaybackStatusChange(availableToWrite, availableToRead, in maySendPlaybackStatusCallback()
230 PlaybackStatus Dvr::checkPlaybackStatusChange(uint32_t availableToWrite, uint32_t availableToRead, in checkPlaybackStatusChange() argument
234 } else if (availableToRead > highThreshold) { in checkPlaybackStatusChange()
236 } else if (availableToRead < lowThreshold) { in checkPlaybackStatusChange()
238 } else if (availableToRead == 0) { in checkPlaybackStatusChange()
246 int size = mDvrMQ->availableToRead(); in readPlaybackFMQ()
273 int size = mDvrMQ->availableToRead(); in processEsDataOnPlayback()
440 int availableToRead = mDvrMQ->availableToRead(); in maySendRecordStatusCallback() local
443 RecordStatus newStatus = checkRecordStatusChange(availableToWrite, availableToRead, in maySendRecordStatusCallback()
[all …]
|
| D | Filter.cpp | 146 int size = mFilterMQ->availableToRead(); in flush()
288 int availableToRead = mFilterMQ->availableToRead(); in maySendFilterStatusCallback() local
293 availableToWrite, availableToRead, ceil(fmqSize * 0.75), ceil(fmqSize * 0.25)); in maySendFilterStatusCallback()
301 uint32_t availableToRead, uint32_t highThreshold, in checkFilterStatusChange() argument
305 } else if (availableToRead > highThreshold) { in checkFilterStatusChange()
307 } else if (availableToRead < lowThreshold) { in checkFilterStatusChange()
|
| D | Dvr.h | 115 PlaybackStatus checkPlaybackStatusChange(uint32_t availableToWrite, uint32_t availableToRead,
117 RecordStatus checkRecordStatusChange(uint32_t availableToWrite, uint32_t availableToRead,
|
| D | Filter.h | 163 DemuxFilterStatus checkFilterStatusChange(uint32_t availableToWrite, uint32_t availableToRead,
|
| /hardware/interfaces/tv/tuner/1.1/default/ |
| D | Dvr.cpp | 245 int availableToRead = mDvrMQ->availableToRead(); in maySendPlaybackStatusCallback() local
248 PlaybackStatus newStatus = checkPlaybackStatusChange(availableToWrite, availableToRead, in maySendPlaybackStatusCallback()
257 PlaybackStatus Dvr::checkPlaybackStatusChange(uint32_t availableToWrite, uint32_t availableToRead, in checkPlaybackStatusChange() argument
261 } else if (availableToRead > highThreshold) { in checkPlaybackStatusChange()
263 } else if (availableToRead < lowThreshold) { in checkPlaybackStatusChange()
265 } else if (availableToRead == 0) { in checkPlaybackStatusChange()
273 int size = mDvrMQ->availableToRead(); in readPlaybackFMQ()
300 int size = mDvrMQ->availableToRead(); in processEsDataOnPlayback()
467 int availableToRead = mDvrMQ->availableToRead(); in maySendRecordStatusCallback() local
470 RecordStatus newStatus = checkRecordStatusChange(availableToWrite, availableToRead, in maySendRecordStatusCallback()
[all …]
|
| D | Dvr.h | 111 PlaybackStatus checkPlaybackStatusChange(uint32_t availableToWrite, uint32_t availableToRead,
113 RecordStatus checkRecordStatusChange(uint32_t availableToWrite, uint32_t availableToRead,
|
| D | Filter.cpp | 199 int size = mFilterMQ->availableToRead(); in flush()
502 int availableToRead = mFilterMQ->availableToRead(); in maySendFilterStatusCallback() local
507 availableToWrite, availableToRead, ceil(fmqSize * 0.75), ceil(fmqSize * 0.25)); in maySendFilterStatusCallback()
519 uint32_t availableToRead, uint32_t highThreshold, in checkFilterStatusChange() argument
523 } else if (availableToRead > highThreshold) { in checkFilterStatusChange()
525 } else if (availableToRead < lowThreshold) { in checkFilterStatusChange()
|
| D | Filter.h | 182 DemuxFilterStatus checkFilterStatusChange(uint32_t availableToWrite, uint32_t availableToRead,
|
| /hardware/interfaces/sensors/common/utils/ |
| D | EventMessageQueueWrapper.h | 41 virtual size_t availableToRead() = 0;
67 virtual size_t availableToRead() override { return mQueue->availableToRead(); } in availableToRead() function
110 virtual size_t availableToRead() override { return mQueue->availableToRead(); } in availableToRead() function
|
| /hardware/interfaces/bluetooth/audio/utils/session/ |
| D | BluetoothAudioSession.cpp | 449 size_t availableToRead = mDataMQ->availableToRead(); in InReadPcmData() local
450 if (availableToRead) { in InReadPcmData()
451 if (availableToRead > (bytes - totalRead)) { in InReadPcmData()
452 availableToRead = bytes - totalRead; in InReadPcmData()
455 availableToRead)) { in InReadPcmData()
459 totalRead += availableToRead; in InReadPcmData()
|
| /hardware/interfaces/sensors/common/vts/2_X/ |
| D | SensorsHidlEnvironmentV2_X.cpp | 127 size_t availableEvents = mSensors->getEventQueue()->availableToRead(); in readEvents()
133 availableEvents = mSensors->getEventQueue()->availableToRead(); in readEvents()
|
| /hardware/interfaces/sensors/aidl/vts/ |
| D | SensorsAidlEnvironment.cpp | 136 size_t availableEvents = mEventQueue->availableToRead(); in readEvents()
142 availableEvents = mEventQueue->availableToRead(); in readEvents()
|
| /hardware/interfaces/sensors/aidl/default/multihal/include/ |
| D | EventMessageQueueWrapperAidl.h | 44 virtual size_t availableToRead() override { return mQueue->availableToRead(); } in availableToRead() function
|
| /hardware/interfaces/media/bufferpool/aidl/default/ |
| D | BufferStatus.cpp | 83 size_t avail = it->second->availableToRead(); in getBufferStatusChanges()
225 mBufferInvalidationQueue->availableToRead(), (size_t) kNumElementsInQueue); in BufferInvalidationListener()
238 mBufferInvalidationQueue->availableToRead(), (size_t) kNumElementsInQueue); in getInvalidations()
|
| /hardware/interfaces/sensors/common/default/2.X/multihal/tests/ |
| D | HalProxy_test.cpp | 326 EXPECT_EQ(eventQueue->availableToRead(), 1); in TEST()
343 EXPECT_EQ(eventQueue->availableToRead(), kNumEvents); in TEST()
365 EXPECT_EQ(eventQueue->availableToRead(), 1); in TEST()
391 EXPECT_EQ(eventQueue->availableToRead(), kNumEvents); in TEST()
411 EXPECT_EQ(eventQueue->availableToRead(), kNumEvents); in TEST()
415 EXPECT_EQ(eventQueue->availableToRead(), kNumEvents * 2); in TEST()
435 EXPECT_EQ(eventQueue->availableToRead(), kQueueSize); in TEST()
443 EXPECT_EQ(eventQueue->availableToRead(), 0); in TEST()
467 EXPECT_EQ(eventQueue->availableToRead(), kNumEvents * 2); in TEST()
827 EXPECT_EQ(eventQueue->availableToRead(), kNumEvents * 2); in TEST()
|
| /hardware/interfaces/audio/aidl/default/ |
| D | EffectContext.cpp | 58 std::vector<IEffect::Status> status(mStatusMQ->availableToRead()); in resetBuffer()
61 mInputMQ->read(buffer, mInputMQ->availableToRead()); in resetBuffer()
|
| D | EffectImpl.cpp | 345 std::max(inputMQ->availableToRead(), outputMQ->availableToWrite())); in process()
346 auto processSamples = std::min(inputMQ->availableToRead(), outputMQ->availableToWrite()); in process()
|
| /hardware/interfaces/neuralnetworks/1.2/utils/src/ |
| D | BurstUtils.cpp | 522 const size_t available = mFmqRequestChannel.availableToRead(); in getPacketBlocking()
548 const size_t count = mFmqRequestChannel.availableToRead(); in getPacketBlocking()
669 const size_t available = mFmqResultChannel.availableToRead(); in getPacketBlocking()
695 const size_t count = mFmqResultChannel.availableToRead(); in getPacketBlocking()
|
| /hardware/interfaces/audio/aidl/vts/ |
| D | EffectHelper.h | 192 ASSERT_EQ(0ul, statusMq->availableToRead());
202 ASSERT_EQ(expectFloats, dataMq->availableToRead());
|
| /hardware/interfaces/tv/tuner/1.0/vts/functional/ |
| D | DvrTests.cpp | 194 int readSize = mRecordMQ->availableToRead(); in readRecordFMQ()
|
| /hardware/interfaces/tv/tuner/1.1/vts/functional/ |
| D | DvrTests.cpp | 193 int readSize = mRecordMQ->availableToRead(); in readRecordFMQ()
|