Searched defs:ReadThread (Results 1 – 1 of 1) sorted by relevance
42 struct ReadThread : public IOThread { struct43 typedef MessageQueue<IStreamIn::ReadParameters, kSynchronizedReadWrite> CommandMQ;44 typedef MessageQueue<IStreamIn::ReadStatus, kSynchronizedReadWrite> StatusMQ;45 typedef MessageQueue<uint8_t, kSynchronizedReadWrite> DataMQ;47 ReadThread(StreamIn *stream, const size_t bufferSize) in ReadThread() function79 ~ReadThread() { in ~ReadThread()86 EventFlag *getEventFlag() override { in getEventFlag()90 bool isRunning() const { in isRunning()94 std::future<pthread_t> getTid() { in getTid()98 void threadLoop() { in threadLoop()[all …]