Searched refs:mFmqRequestChannel (Results 1 – 4 of 4) sorted by relevance
334 : mFmqRequestChannel(std::move(fmqRequestChannel)), kPollingTimeWindow(pollingTimeWindow) {} in RequestChannelReceiver()359 mFmqRequestChannel->writeBlocking(&datum, 1); in invalidate()384 const size_t available = mFmqRequestChannel->availableToRead(); in getPacketBlocking()394 const bool success = mFmqRequestChannel->read(packet.data(), available); in getPacketBlocking()409 bool success = mFmqRequestChannel->readBlocking(&datum, 1); in getPacketBlocking()424 const size_t count = mFmqRequestChannel->availableToRead(); in getPacketBlocking()427 success &= mFmqRequestChannel->read(packet.data() + 1, count); in getPacketBlocking()
364 : mFmqRequestChannel(std::move(fmqRequestChannel)) {} in RequestChannelSender()377 if (packet.size() > mFmqRequestChannel->availableToWrite()) { in sendPacket()385 return mFmqRequestChannel->writeBlocking(packet.data(), packet.size()); in sendPacket()
130 const std::unique_ptr<FmqRequestChannel> mFmqRequestChannel; variable
200 const std::unique_ptr<FmqRequestChannel> mFmqRequestChannel;