Searched defs:commandMQ (Results 1 – 4 of 4) sorted by relevance
84 StreamContext(std::unique_ptr<CommandMQ> commandMQ, std::unique_ptr<ReplyMQ> replyMQ, in StreamContext()107 StreamContext(std::unique_ptr<CommandMQ> commandMQ, std::unique_ptr<ReplyMQ> replyMQ, in StreamContext()
51 ReadThread(std::atomic<bool>* stop, audio_stream_in_t* stream, StreamIn::CommandMQ* commandMQ, in ReadThread()
54 StreamOut::CommandMQ* commandMQ, StreamOut::DataMQ* dataMQ, in WriteThread()
914 if (auto commandMQ = mContext.getCommandMQ(); commandMQ != nullptr) { in stopWorker() local