Searched defs:WriteThread (Results 1 – 4 of 4) sorted by relevance
49 struct WriteThread : public IOThread { struct50 typedef MessageQueue<IStreamOut::WriteCommand, kSynchronizedReadWrite> CommandMQ;51 typedef MessageQueue<IStreamOut::WriteStatus, kSynchronizedReadWrite> StatusMQ;52 typedef MessageQueue<uint8_t, kSynchronizedReadWrite> DataMQ;54 WriteThread(StreamOut *stream, const size_t mqBufferSize) in WriteThread() argument86 ~WriteThread() { in ~WriteThread()93 EventFlag *getEventFlag() override { in getEventFlag()97 bool isRunning() const { in isRunning()101 std::future<pthread_t> getTid() { in getTid()106 void threadLoop() { in threadLoop()[all …]
45 class WriteThread : public Thread { class68 WriteThread::WriteThread(std::atomic<bool>* stop, AudioProxyStreamOut* stream, in WriteThread() function in audio_proxy::__anon2d3f4c720111::WriteThread
43 class WriteThread; variable
27 WriteThread::WriteThread(std::shared_ptr<BusOutputStream> stream, in WriteThread() function in audio_proxy::service::WriteThread