Searched refs:mMsgQueue (Results 1 – 3 of 3) sorted by relevance
82 private final MessageQueue mMsgQueue; field in LmkdConnection118 mMsgQueue = msgQueue; in LmkdConnection()154 mMsgQueue.addOnFileDescriptorEventListener(mLmkdSocket.getFileDescriptor(), in connect()177 mMsgQueue.removeOnFileDescriptorEventListener( in fileDescriptorEventHandler()
273 mMsgQueue = std::make_unique<MsgQueue>(std::move(channelConfig.channelDescriptor), true); in setUpFmq()274 LOG_ALWAYS_FATAL_IF(!mMsgQueue->isValid(), "Failed to set up hint session msg queue"); in setUpFmq()283 mMsgQueue = nullptr; in setUpFmq()381 if (!mMsgQueue) { in writeHintSessionMessage()385 auto availableSize = mMsgQueue->availableToWrite(); in writeHintSessionMessage()391 if (!mMsgQueue->beginWrite(count, &tx)) { in writeHintSessionMessage()418 if (!mMsgQueue->commitWrite(count)) { in writeHintSessionMessage()
280 mMsgQueue GUARDED_BY(mHintSessionMutex);