Searched defs:commandMQ (Results 1 – 4 of 4) sorted by relevance
727 if (auto commandMQ = mContext.getCommandMQ(); commandMQ != nullptr) { in stopWorker() local
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()
82 StreamContext(std::unique_ptr<CommandMQ> commandMQ, std::unique_ptr<ReplyMQ> replyMQ, in StreamContext()