Home
last modified time | relevance | path

Searched refs:mFmqRequestChannel (Results 1 – 6 of 6) sorted by relevance

/aosp12/hardware/interfaces/neuralnetworks/1.2/utils/src/
H A DExecutionBurstUtils.cpp410 if (!requestChannelSender->mFmqRequestChannel.isValid()) { in create()
415 requestChannelSender->mFmqRequestChannel.getDesc(); in create()
420 : mFmqRequestChannel(channelLength, /*configureEventFlagWord=*/true) {} in RequestChannelSender()
434 if (packet.size() > mFmqRequestChannel.availableToWrite()) { in sendPacket()
462 if (!requestChannelReceiver->mFmqRequestChannel.isValid()) { in create()
476 : mFmqRequestChannel(requestChannel), kPollingTimeWindow(pollingTimeWindow) {} in RequestChannelReceiver()
492 mFmqRequestChannel.writeBlocking(data.data(), data.size()); in invalidate()
514 const size_t available = mFmqRequestChannel.availableToRead(); in getPacketBlocking()
532 bool success = mFmqRequestChannel.readBlocking(&datum, 1); in getPacketBlocking()
540 const size_t count = mFmqRequestChannel.availableToRead(); in getPacketBlocking()
[all …]
/aosp12/packages/modules/NeuralNetworks/common/
H A DExecutionBurstServer.cpp337 : mFmqRequestChannel(std::move(fmqRequestChannel)), kPollingTimeWindow(pollingTimeWindow) {} in RequestChannelReceiver()
362 mFmqRequestChannel->writeBlocking(&datum, 1); in invalidate()
387 const size_t available = mFmqRequestChannel->availableToRead(); in getPacketBlocking()
397 const bool success = mFmqRequestChannel->read(packet.data(), available); in getPacketBlocking()
414 bool success = mFmqRequestChannel->readBlocking(&datum, 1); in getPacketBlocking()
429 const size_t count = mFmqRequestChannel->availableToRead(); in getPacketBlocking()
432 success &= mFmqRequestChannel->read(packet.data() + 1, count); in getPacketBlocking()
H A DExecutionBurstController.cpp366 : mFmqRequestChannel(std::move(fmqRequestChannel)) {} in RequestChannelSender()
379 if (packet.size() > mFmqRequestChannel->availableToWrite()) { in sendPacket()
387 return mFmqRequestChannel->writeBlocking(packet.data(), packet.size()); in sendPacket()
/aosp12/hardware/interfaces/neuralnetworks/1.2/utils/include/nnapi/hal/1.2/
H A DExecutionBurstUtils.h149 MessageQueue<FmqRequestDatum, kSynchronizedReadWrite> mFmqRequestChannel;
202 MessageQueue<FmqRequestDatum, kSynchronizedReadWrite> mFmqRequestChannel; variable
/aosp12/packages/modules/NeuralNetworks/common/include/
H A DExecutionBurstServer.h130 const std::unique_ptr<FmqRequestChannel> mFmqRequestChannel; variable
H A DExecutionBurstController.h200 const std::unique_ptr<FmqRequestChannel> mFmqRequestChannel;