Home
last modified time | relevance | path

Searched refs:readBlocking (Results 1 – 12 of 12) sorted by relevance

/aosp12/hardware/interfaces/tests/msgq/1.0/default/
H A DTestMsgQ.cpp101 bool result = mFmqSynchronized->readBlocking( in requestBlockingRead()
116 bool result = mFmqSynchronized->readBlocking( in requestBlockingReadDefaultEventFlagBits()
130 bool result = mFmqSynchronized->readBlocking( in requestBlockingReadRepeat()
/aosp12/system/libfmq/tests/aidl/default/
H A DTestAidlMsgQ.cpp71 bool result = mFmqSynchronized->readBlocking( in requestBlockingRead()
83 bool result = mFmqSynchronized->readBlocking(&data[0], count); in requestBlockingReadDefaultEventFlagBits()
95 bool result = mFmqSynchronized->readBlocking( in requestBlockingReadRepeat()
/aosp12/hardware/interfaces/neuralnetworks/1.2/utils/src/
H A DExecutionBurstUtils.cpp517 const bool success = mFmqRequestChannel.readBlocking(packet.data(), available); in getPacketBlocking()
532 bool success = mFmqRequestChannel.readBlocking(&datum, 1); in getPacketBlocking()
664 const bool success = mFmqResultChannel.readBlocking(packet.data(), available); in getPacketBlocking()
679 bool success = mFmqResultChannel.readBlocking(&datum, 1); in getPacketBlocking()
/aosp12/system/libfmq/include/fmq/
H A DMessageQueueBase.h220 bool readBlocking(T* data, size_t count, uint32_t readNotification, uint32_t writeNotification,
223 bool readBlocking(T* data, size_t count, int64_t timeOutNanos = 0);
929 bool MessageQueueBase<MQDescriptorType, T, flavor>::readBlocking( in readBlocking() function
1039 bool MessageQueueBase<MQDescriptorType, T, flavor>::readBlocking(T* data, size_t count, in readBlocking() function
1041 return readBlocking(data, count, FMQ_NOT_FULL, FMQ_NOT_EMPTY, timeOutNanos); in readBlocking()
/aosp12/hardware/interfaces/sensors/common/default/2.X/
H A DSensors.h246 mWakeLockQueue->readBlocking(&eventsHandled, 1 /* count */, 0 /* readNotification */, in readWakeLockFMQ()
/aosp12/packages/modules/NeuralNetworks/common/
H A DExecutionBurstController.cpp324 bool success = mFmqResultChannel->readBlocking(&datum, 1); in getPacketBlocking()
H A DExecutionBurstServer.cpp414 bool success = mFmqRequestChannel->readBlocking(&datum, 1); in getPacketBlocking()
/aosp12/hardware/interfaces/power/stats/1.0/vts/functional/
H A DVtsHalPowerStatsV1_0TargetTest.cpp522 rc = mQueue->readBlocking(&data[0], batch, timeout_ns); in readEnergy()
/aosp12/hardware/interfaces/sensors/common/default/2.X/multihal/
H A DHalProxy.cpp615 bool success = mWakeLockQueue->readBlocking( in handleWakelocks()
/aosp12/system/libfmq/tests/
H A Dmsgq_test_client.cpp625 ret = this->mQueue->readBlocking( in TYPED_TEST()
H A Dfmq_unit_tests.cpp290 bool ret = fmq->readBlocking(data, in ReaderThreadBlocking2()
/aosp12/hardware/interfaces/sensors/common/default/2.X/multihal/tests/
H A DHalProxy_test.cpp872 return eventQueue->readBlocking(events.data(), numEvents, in readEventsOutOfQueue()