44 struct WriteThread : public IOThread {  struct
45     typedef MessageQueue<IStreamOut::WriteCommand, kSynchronizedReadWrite> CommandMQ;
46     typedef MessageQueue<IStreamOut::WriteStatus, kSynchronizedReadWrite> StatusMQ;
47     typedef MessageQueue<uint8_t, kSynchronizedReadWrite> DataMQ;
49     WriteThread(StreamOut *stream, const size_t mqBufferSize)  in WriteThread()  argument
81     ~WriteThread() {  in ~WriteThread()
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()
131     void processCommand() {  in processCommand()
168     IStreamOut::WriteStatus doWrite() {  in doWrite()
196     IStreamOut::WriteStatus doGetPresentationPosition() {  in doGetPresentationPosition()
206     IStreamOut::WriteStatus doGetLatency() {  in doGetLatency()
215     StreamOut *const mStream;
216     CommandMQ mCommandMQ;
217     StatusMQ mStatusMQ;
218     DataMQ mDataMQ;
219     std::unique_ptr<EventFlag, deleters::forEventFlag> mEfGroup;
220     std::unique_ptr<DevicePortSink> mSink;
221     std::thread mThread;
222     std::promise<pthread_t> mTid;