| /aosp12/hardware/interfaces/sensors/common/utils/ |
| H A D | EventMessageQueueWrapper.h | 46 virtual bool writeBlocking(const V2_1::Event* events, size_t count, uint32_t readNotification,
84 bool writeBlocking(const V2_1::Event* events, size_t count, uint32_t readNotification, in writeBlocking() function
87 return mQueue->writeBlocking(reinterpret_cast<const V1_0::Event*>(events), count, in writeBlocking()
126 bool writeBlocking(const V2_1::Event* events, size_t count, uint32_t readNotification, in writeBlocking() function
129 return mQueue->writeBlocking(events, count, readNotification, writeNotification, in writeBlocking()
|
| /aosp12/system/libfmq/tests/ |
| H A D | msgq_test_client.cpp | 418 ret = this->mQueue->writeBlocking( in TYPED_TEST()
427 ret = this->mQueue->writeBlocking( in TYPED_TEST()
456 ret = this->mQueue->writeBlocking(data.data(), data.size()); in TYPED_TEST()
466 ret = this->mQueue->writeBlocking(data.data(), data.size(), 5000000000 /* timeOutNanos */); in TYPED_TEST()
493 ret = this->mQueue->writeBlocking( in TYPED_TEST()
507 ret = this->mQueue->writeBlocking( in TYPED_TEST()
539 ret = this->mQueue->writeBlocking( in TYPED_TEST()
553 ret = this->mQueue->writeBlocking( in TYPED_TEST()
584 ret = this->mQueue->writeBlocking( in TYPED_TEST()
598 ret = this->mQueue->writeBlocking( in TYPED_TEST()
[all …]
|
| H A D | fmq_unit_tests.cpp | 606 bool ret = this->mQueue->writeBlocking(data, dataLen, static_cast<uint32_t>(kFmqNotFull), in TYPED_TEST()
648 bool ret = this->mQueue->writeBlocking(data, dataLen, static_cast<uint32_t>(kFmqNotFull), in TYPED_TEST()
|
| /aosp12/hardware/interfaces/neuralnetworks/1.2/utils/src/ |
| H A D | ExecutionBurstUtils.cpp | 441 const bool success = mFmqRequestChannel.writeBlocking(packet.data(), packet.size()); in sendPacket()
492 mFmqRequestChannel.writeBlocking(data.data(), data.size()); in invalidate()
596 mFmqResultChannel.writeBlocking(errorPacket.data(), errorPacket.size()); in sendPacket()
600 mFmqResultChannel.writeBlocking(packet.data(), packet.size()); in sendPacket()
639 mFmqResultChannel.writeBlocking(data.data(), data.size()); in notifyAsDeadObject()
|
| /aosp12/system/libfmq/include/fmq/ |
| H A D | MessageQueueBase.h | 169 bool writeBlocking(const T* data, size_t count, uint32_t readNotification,
173 bool writeBlocking(const T* data, size_t count, int64_t timeOutNanos = 0);
813 bool MessageQueueBase<MQDescriptorType, T, flavor>::writeBlocking( in writeBlocking() function
923 bool MessageQueueBase<MQDescriptorType, T, flavor>::writeBlocking(const T* data, size_t count, in writeBlocking() function
925 return writeBlocking(data, count, FMQ_NOT_FULL, FMQ_NOT_EMPTY, timeOutNanos); in writeBlocking()
|
| /aosp12/packages/modules/NeuralNetworks/common/ |
| H A D | ExecutionBurstServer.cpp | 362 mFmqRequestChannel->writeBlocking(&datum, 1); in invalidate()
486 return mFmqResultChannel->writeBlocking(errorPacket.data(), errorPacket.size()); in sendPacket()
491 return mFmqResultChannel->writeBlocking(packet.data(), packet.size()); in sendPacket()
|
| H A D | ExecutionBurstController.cpp | 280 mFmqResultChannel->writeBlocking(&datum, 1); in invalidate()
387 return mFmqRequestChannel->writeBlocking(packet.data(), packet.size()); in sendPacket()
|
| /aosp12/hardware/interfaces/sensors/2.0/ |
| H A D | types.hal | 37 * If the MessageQueue::writeBlocking function is being used to write sensor
|
| H A D | ISensors.hal | 87 * 2) Setting the write notification in the Event FMQ’s writeBlocking()
90 * If the Event FMQ’s writeBlocking() function is used, the read
|
| /aosp12/hardware/interfaces/sensors/2.1/ |
| H A D | ISensors.hal | 54 * 2) Setting the write notification in the Event FMQ’s writeBlocking()
57 * If the Event FMQ’s writeBlocking() function is used, the read
|
| /aosp12/hardware/interfaces/neuralnetworks/1.2/ |
| H A D | IPreparedModel.hal | 174 * MessageQueue::writeBlocking if the queue is
187 * MessageQueue::writeBlocking if the queue is
|
| /aosp12/hardware/interfaces/power/stats/1.0/default/ |
| H A D | PowerStats.cpp | 270 mPm.fmqSynchronized->writeBlocking(&mPm.reading[0], mPm.reading.size(), in streamEnergyData()
|
| /aosp12/hardware/interfaces/sensors/common/default/2.X/multihal/ |
| H A D | HalProxy.cpp | 571 if (!mEventQueue->writeBlocking( in handlePendingWrites()
|