Searched refs:mFmqRequestChannel (Results 1 – 4 of 4) sorted by relevance
343 : mFmqRequestChannel(std::move(fmqRequestChannel)), kPollingTimeWindow(pollingTimeWindow) {} in RequestChannelReceiver()368 mFmqRequestChannel->writeBlocking(&datum, 1); in invalidate()393 const size_t available = mFmqRequestChannel->availableToRead(); in getPacketBlocking()403 const bool success = mFmqRequestChannel->read(packet.data(), available); in getPacketBlocking()420 bool success = mFmqRequestChannel->readBlocking(&datum, 1); in getPacketBlocking()435 const size_t count = mFmqRequestChannel->availableToRead(); in getPacketBlocking()438 success &= mFmqRequestChannel->read(packet.data() + 1, count); in getPacketBlocking()
371 : mFmqRequestChannel(std::move(fmqRequestChannel)) {} in RequestChannelSender()384 if (packet.size() > mFmqRequestChannel->availableToWrite()) { in sendPacket()392 return mFmqRequestChannel->writeBlocking(packet.data(), packet.size()); in sendPacket()
130 const std::unique_ptr<FmqRequestChannel> mFmqRequestChannel; variable
200 const std::unique_ptr<FmqRequestChannel> mFmqRequestChannel;