Searched defs:ReadThread (Results 1 – 1 of 1) sorted by relevance
47 struct ReadThread : public IOThread { struct48 typedef MessageQueue<IStreamIn::ReadParameters, kSynchronizedReadWrite> CommandMQ;49 typedef MessageQueue<IStreamIn::ReadStatus, kSynchronizedReadWrite> StatusMQ;50 typedef MessageQueue<uint8_t, kSynchronizedReadWrite> DataMQ;52 ReadThread(StreamIn *stream, const size_t bufferSize) in ReadThread() function84 ~ReadThread() { in ~ReadThread()91 EventFlag *getEventFlag() override { in getEventFlag()95 bool isRunning() const { in isRunning()99 std::future<pthread_t> getTid() { in getTid()103 void threadLoop() { in threadLoop()[all …]