Searched defs:WriteThread (Results 1 – 1 of 1) sorted by relevance
44 struct WriteThread : public IOThread { struct45 typedef MessageQueue<IStreamOut::WriteCommand, kSynchronizedReadWrite> CommandMQ;46 typedef MessageQueue<IStreamOut::WriteStatus, kSynchronizedReadWrite> StatusMQ;47 typedef MessageQueue<uint8_t, kSynchronizedReadWrite> DataMQ;49 WriteThread(StreamOut *stream, const size_t mqBufferSize) in WriteThread() function81 ~WriteThread() { in ~WriteThread()88 EventFlag *getEventFlag() override { in getEventFlag()92 bool isRunning() const { in isRunning()96 std::future<pthread_t> getTid() { in getTid()100 void threadLoop() { in threadLoop()[all …]