Lines Matching refs:mFmqRequestChannel

410     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()
441     const bool success = mFmqRequestChannel.writeBlocking(packet.data(), packet.size());  in sendPacket()
462     if (!requestChannelReceiver->mFmqRequestChannel.isValid()) {  in create()
465     if (requestChannelReceiver->mFmqRequestChannel.getEventFlagWord() == nullptr) {  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()
517             const bool success = mFmqRequestChannel.readBlocking(packet.data(), available);  in getPacketBlocking()
532     bool success = mFmqRequestChannel.readBlocking(&datum, 1);  in getPacketBlocking()
540     const size_t count = mFmqRequestChannel.availableToRead();  in getPacketBlocking()
543     success &= mFmqRequestChannel.read(packet.data() + 1, count);  in getPacketBlocking()