44 struct ReadThread : public IOThread {  struct
45     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()  function
81     ~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()
135     void processCommand() {  in processCommand()
168     IStreamIn::ReadStatus doRead(const IStreamIn::ReadParameters &rParameters) {  in doRead()
185     Result doReadImpl(uint8_t *const data, const size_t toRead, size_t &read) {  in doReadImpl()
199     IStreamIn::ReadStatus doGetCapturePosition() {  in doGetCapturePosition()
209     StreamIn *const mStream;
210     CommandMQ mCommandMQ;
211     StatusMQ mStatusMQ;
212     DataMQ mDataMQ;
213     std::unique_ptr<EventFlag, deleters::forEventFlag> mEfGroup;
214     std::unique_ptr<uint8_t[]> mBuffer;
215     std::unique_ptr<DevicePortSource> mSource;
216     std::thread mThread;
217     std::promise<pthread_t> mTid;