Searched defs:ReadThread (Results 1 – 4 of 4) 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() argument84 ~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 …]
59 class ReadThread : public BaseThread { class61 explicit ReadThread(size_t id) in ReadThread() function in base::__anone824456e0111::ReadThread
48 class ReadThread : public Thread { class51 ReadThread(std::atomic<bool>* stop, audio_stream_in_t* stream, StreamIn::CommandMQ* commandMQ, in ReadThread() function in android::hardware::audio::CPP_VERSION::implementation::__anon9376bb540111::ReadThread
358 void ReadThread(Stream* stream, absl::Notification* shutdown) { in ReadThread() function in grpc::testing::__anon1a9bc1970111::BalancerServiceImpl