Home
last modified time | relevance | path

Searched refs:mEventFlag (Results 1 – 8 of 8) sorted by relevance

/device/google/atv/audio_proxy/
DOutputStreamImpl.cpp63 EventFlag* const mEventFlag; member in audio_proxy::__anonaf206e460111::WriteThread
76 mEventFlag(eventFlag), in WriteThread()
106 mEventFlag->wait(static_cast<uint32_t>(MessageQueueFlag::NOT_EMPTY), in threadLoop()
119 mEventFlag->wake(static_cast<uint32_t>(MessageQueueFlag::NOT_FULL)); in threadLoop()
128 : mStream(std::move(stream)), mEventFlag(nullptr, deleteEventFlag) {} in OutputStreamImpl()
140 mEventFlag.reset(); in ~OutputStreamImpl()
156 if (mEventFlag) { in closeImpl()
157 mEventFlag->wake(static_cast<uint32_t>(MessageQueueFlag::NOT_EMPTY)); in closeImpl()
222 mEventFlag = std::move(eventFlag); in prepareForWriting()
DOutputStreamImpl.h79 std::unique_ptr<EventFlag, EventFlagDeleter> mEventFlag; variable
/device/google/atv/audio_proxy/service/
DRemoteBusOutputStream.cpp50 mEventFlag(nullptr, deleteEventFlag) {} in RemoteBusOutputStream()
81 DCHECK(mEventFlag); in writeRingBuffer()
101 mEventFlag->wake(static_cast<uint32_t>(MessageQueueFlag::NOT_EMPTY)); in writeRingBuffer()
113 kFmqReadTimeoutNs, mEventFlag.get())) { in writeRingBuffer()
157 mEventFlag = std::move(eventFlag); in prepareForWritingImpl()
DWriteThread.cpp36 mEventFlag(eventFlag), in WriteThread()
47 mEventFlag->wake(static_cast<uint32_t>(MessageQueueFlagBits::NOT_EMPTY)); in stop()
145 mEventFlag->wait(static_cast<uint32_t>(MessageQueueFlagBits::NOT_EMPTY), in threadLoop()
187 mEventFlag->wake(static_cast<uint32_t>(MessageQueueFlagBits::NOT_FULL)); in threadLoop()
DStreamOutImpl.cpp82 mEventFlag(nullptr, deleteEventFlag) {} in StreamOutImpl()
93 mEventFlag.reset(); in ~StreamOutImpl()
327 mEventFlag = std::move(eventFlag); in prepareForWriting()
DRemoteBusOutputStream.h72 std::unique_ptr<EventFlag, EventFlagDeleter> mEventFlag; variable
DWriteThread.h97 EventFlag* const mEventFlag; variable
DStreamOutImpl.h179 std::unique_ptr<EventFlag, EventFlagDeleter> mEventFlag; variable