Searched refs:getReplyMQ (Results 1 – 3 of 3) sorted by relevance
118 if (mContext->getReplyMQ() == nullptr) return "Reply MQ is null"; in init()309 if (!mContext->getReplyMQ()->writeBlocking(&reply, 1)) { in cycle()587 if (!mContext->getReplyMQ()->writeBlocking(&reply, 1)) { in cycle()
132 ReplyMQ* getReplyMQ() const { return mReplyMQ.get(); } in getReplyMQ() function
660 ReplyMQ* getReplyMQ() const { return mReplyMQ.get(); } in getReplyMQ() function in StreamContext867 mReplyMQ(context.getReplyMQ()), in StreamCommonLogic()873 StreamContext::ReplyMQ* getReplyMQ() const { return mReplyMQ; } in getReplyMQ() function in StreamCommonLogic954 if (!getReplyMQ()->readBlocking(&reply, 1)) { in cycle()1041 if (!getReplyMQ()->readBlocking(&reply, 1)) { in cycle()