Lines Matching refs:mFmqRequestChannel

418     if (!requestChannelSender->mFmqRequestChannel.isValid()) {  in create()
423             requestChannelSender->mFmqRequestChannel.getDesc();  in create()
428     : mFmqRequestChannel(channelLength, /*configureEventFlagWord=*/true) {}  in RequestChannelSender()
442     if (packet.size() > mFmqRequestChannel.availableToWrite()) {  in sendPacket()
449     const bool success = mFmqRequestChannel.writeBlocking(packet.data(), packet.size());  in sendPacket()
470     if (!requestChannelReceiver->mFmqRequestChannel.isValid()) {  in create()
473     if (requestChannelReceiver->mFmqRequestChannel.getEventFlagWord() == nullptr) {  in create()
484     : mFmqRequestChannel(requestChannel), kPollingTimeWindow(pollingTimeWindow) {}  in RequestChannelReceiver()
500     mFmqRequestChannel.writeBlocking(data.data(), data.size());  in invalidate()
522         const size_t available = mFmqRequestChannel.availableToRead();  in getPacketBlocking()
525             const bool success = mFmqRequestChannel.readBlocking(packet.data(), available);  in getPacketBlocking()
540     bool success = mFmqRequestChannel.readBlocking(&datum, 1);  in getPacketBlocking()
548     const size_t count = mFmqRequestChannel.availableToRead();  in getPacketBlocking()
551     success &= mFmqRequestChannel.read(packet.data() + 1, count);  in getPacketBlocking()