Searched refs:statusMQ (Results 1 – 5 of 5) sorted by relevance
190 auto statusMQ = mImplContext->getStatusFmq(); in process() local209 statusMQ->writeBlocking(&status, 1); in process()
125 [&](Result r, const MQDescriptorSync<Result>& statusMQ) { in prepareForProcessing() argument128 tempStatusMQ.reset(new StatusMQ(statusMQ)); in prepareForProcessing()
117 sub.effectMq.statusQ = std::make_shared<StatusMQ>(openReturn.statusMQ); in open()142 sub.effectMq.statusQ = std::make_shared<StatusMQ>(openReturn.statusMQ); in reopen()
544 const StatusMQ::Descriptor& statusMQ, in prepareForWriting()550 tempStatusMQ.reset(new StatusMQ(statusMQ)); in prepareForWriting()1130 const StatusMQ::Descriptor& statusMQ, in prepareForReading()1136 tempStatusMQ.reset(new StatusMQ(statusMQ)); in prepareForReading()
210 mStatusQ = std::make_shared<StatusMQ>(ret.statusMQ); in updateMqsAndEventFlags()