Searched defs:ReadThread (Results 1 – 1 of 1) sorted by relevance
44 struct ReadThread : public IOThread { struct45 typedef MessageQueue<IStreamIn::ReadParameters, kSynchronizedReadWrite> CommandMQ;46 typedef MessageQueue<IStreamIn::ReadStatus, kSynchronizedReadWrite> StatusMQ;47 typedef MessageQueue<uint8_t, kSynchronizedReadWrite> DataMQ;49 ReadThread(StreamIn *stream, const size_t bufferSize) in ReadThread() argument81 ~ReadThread() { in ~ReadThread()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 …]