47 struct ReadThread : public IOThread {  struct
48     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()  argument
84     ~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()
134     void processCommand() {  in processCommand()
167     IStreamIn::ReadStatus doRead(const IStreamIn::ReadParameters &rParameters) {  in doRead()
202     IStreamIn::ReadStatus doGetCapturePosition() {  in doGetCapturePosition()
212     StreamIn *const mStream;
213     CommandMQ mCommandMQ;
214     StatusMQ mStatusMQ;
215     DataMQ mDataMQ;
216     std::unique_ptr<EventFlag, deleters::forEventFlag> mEfGroup;
217     std::unique_ptr<DevicePortSource> mSource;
218     std::thread mThread;
219     std::promise<pthread_t> mTid;