| /aosp12/system/libfmq/ |
| H A D | EventFlag.cpp | 139 status_t EventFlag::waitHelper(uint32_t bitmask, uint32_t* efState, int64_t timeoutNanoSeconds) { in waitHelper() argument
143 if (bitmask == 0 || efState == nullptr) { in waitHelper()
154 *efState = setBits; in waitHelper()
181 *efState = 0; in waitHelper()
184 *efState = old & bitmask; in waitHelper()
186 if (*efState == 0) { in waitHelper()
200 uint32_t* efState, in wait() argument
204 return waitHelper(bitmask, efState, timeoutNanoSeconds); in wait()
221 *efState = 0; in wait()
226 status = waitHelper(bitmask, efState, timeoutNanoSeconds); in wait()
|
| /aosp12/system/libfmq/include/fmq/ |
| H A D | EventFlag.h | 106 uint32_t* efState,
134 status_t waitHelper(uint32_t bitmask, uint32_t* efState, int64_t timeOutNanoSeconds);
|
| H A D | MessageQueueBase.h | 891 uint32_t efState = 0; in writeBlocking() local
892 status_t status = evFlag->wait(readNotification, &efState, timeOutNanos, in writeBlocking()
909 if ((efState & readNotification) && write(data, count)) { in writeBlocking()
1008 uint32_t efState = 0; in readBlocking() local
1009 status_t status = evFlag->wait(writeNotification, &efState, timeOutNanos, in readBlocking()
1026 if ((efState & writeNotification) && read(data, count)) { in readBlocking()
|
| /aosp12/system/bt/test/mock/ |
| H A D | mock_system_libfmq_eventflag.cc | 82 status_t EventFlag::wait(uint32_t bitmask, uint32_t* efState, in wait() argument
87 status_t EventFlag::waitHelper(uint32_t bitmask, uint32_t* efState, in waitHelper() argument
|
| /aosp12/frameworks/av/media/libaudiohal/impl/ |
| H A D | EffectHalHidl.cpp | 154 uint32_t efState = 0; in processImpl() local
157 static_cast<uint32_t>(MessageQueueFlagBits::DONE_PROCESSING), &efState); in processImpl()
158 if (efState & static_cast<uint32_t>(MessageQueueFlagBits::DONE_PROCESSING)) { in processImpl()
|
| H A D | StreamHalHidl.cpp | 456 uint32_t efState = 0; in callWriterThread() local
458 status_t ret = mEfGroup->wait(static_cast<uint32_t>(MessageQueueFlagBits::NOT_FULL), &efState); in callWriterThread()
459 if (efState & static_cast<uint32_t>(MessageQueueFlagBits::NOT_FULL)) { in callWriterThread()
888 uint32_t efState = 0; in callReaderThread() local
890 status_t ret = mEfGroup->wait(static_cast<uint32_t>(MessageQueueFlagBits::NOT_EMPTY), &efState); in callReaderThread()
891 if (efState & static_cast<uint32_t>(MessageQueueFlagBits::NOT_EMPTY)) { in callReaderThread()
|
| /aosp12/hardware/interfaces/audio/effect/all-versions/default/ |
| H A D | Effect.cpp | 83 uint32_t efState = 0; in threadLoop() local
84 mEfGroup->wait(static_cast<uint32_t>(MessageQueueFlagBits::REQUEST_PROCESS_ALL), &efState); in threadLoop()
85 if (!(efState & static_cast<uint32_t>(MessageQueueFlagBits::REQUEST_PROCESS_ALL)) || in threadLoop()
86 (efState & static_cast<uint32_t>(MessageQueueFlagBits::REQUEST_QUIT))) { in threadLoop()
90 if (efState & static_cast<uint32_t>(MessageQueueFlagBits::REQUEST_PROCESS_REVERSE) && in threadLoop()
104 if (efState & static_cast<uint32_t>(MessageQueueFlagBits::REQUEST_PROCESS)) { in threadLoop()
|
| /aosp12/hardware/interfaces/tv/tuner/1.0/vts/functional/ |
| H A D | DvrTests.cpp | 171 uint32_t efState = 0; in recordThreadLoop() local
173 static_cast<uint32_t>(DemuxQueueNotifyBits::DATA_READY), &efState, WAIT_TIMEOUT, in recordThreadLoop()
|
| /aosp12/hardware/interfaces/tv/tuner/1.1/vts/functional/ |
| H A D | DvrTests.cpp | 170 uint32_t efState = 0; in recordThreadLoop() local
172 static_cast<uint32_t>(DemuxQueueNotifyBits::DATA_READY), &efState, WAIT_TIMEOUT, in recordThreadLoop()
|
| /aosp12/hardware/interfaces/tv/tuner/1.0/default/ |
| H A D | Demux.cpp | 329 uint32_t efState = 0; in frontendInputThreadLoop() local
331 static_cast<uint32_t>(DemuxQueueNotifyBits::DATA_READY), &efState, WAIT_TIMEOUT, in frontendInputThreadLoop()
|
| H A D | Dvr.cpp | 189 uint32_t efState = 0; in playbackThreadLoop() local
192 &efState, WAIT_TIMEOUT, true /* retry on spurious wake */); in playbackThreadLoop()
|
| H A D | Filter.cpp | 233 uint32_t efState = 0; in filterThreadLoop() local
239 static_cast<uint32_t>(DemuxQueueNotifyBits::DATA_CONSUMED), &efState, in filterThreadLoop()
|
| /aosp12/hardware/interfaces/audio/core/all-versions/default/ |
| H A D | StreamIn.cpp | 112 uint32_t efState = 0; in threadLoop() local
113 mEfGroup->wait(static_cast<uint32_t>(MessageQueueFlagBits::NOT_FULL), &efState); in threadLoop()
114 if (!(efState & static_cast<uint32_t>(MessageQueueFlagBits::NOT_FULL))) { in threadLoop()
|
| H A D | StreamOut.cpp | 113 uint32_t efState = 0; in threadLoop() local
114 mEfGroup->wait(static_cast<uint32_t>(MessageQueueFlagBits::NOT_EMPTY), &efState); in threadLoop()
115 if (!(efState & static_cast<uint32_t>(MessageQueueFlagBits::NOT_EMPTY))) { in threadLoop()
|
| /aosp12/hardware/interfaces/tv/tuner/1.1/default/ |
| H A D | Demux.cpp | 355 uint32_t efState = 0; in frontendInputThreadLoop() local
357 static_cast<uint32_t>(DemuxQueueNotifyBits::DATA_READY), &efState, WAIT_TIMEOUT, in frontendInputThreadLoop()
|
| H A D | Dvr.cpp | 211 uint32_t efState = 0; in playbackThreadLoop() local
214 &efState, WAIT_TIMEOUT, true /* retry on spurious wake */); in playbackThreadLoop()
|
| H A D | Filter.cpp | 431 uint32_t efState = 0; in filterThreadLoop() local
440 static_cast<uint32_t>(DemuxQueueNotifyBits::DATA_CONSUMED), &efState, in filterThreadLoop()
|
| /aosp12/system/libfmq/tests/ |
| H A D | fmq_unit_tests.cpp | 259 uint32_t efState = 0; in ReaderThreadBlocking() local
261 &efState, in ReaderThreadBlocking()
268 if ((efState & kFmqNotEmpty) && fmq->read(data, dataLen)) { in ReaderThreadBlocking()
627 uint32_t efState = 0; in TYPED_TEST() local
629 &efState, in TYPED_TEST()
|
| /aosp12/hardware/interfaces/audio/core/all-versions/vts/functional/ |
| H A D | AudioPrimaryHidlHalTest.h | 965 uint32_t efState = 0; in workerCycle() local
968 mEfGroup->wait(static_cast<uint32_t>(MessageQueueFlagBits::NOT_FULL), &efState); in workerCycle()
969 if (efState & static_cast<uint32_t>(MessageQueueFlagBits::NOT_FULL)) { in workerCycle()
1149 uint32_t efState = 0; in workerCycle() local
1153 mEfGroup->wait(static_cast<uint32_t>(MessageQueueFlagBits::NOT_EMPTY), &efState); in workerCycle()
1154 if (efState & static_cast<uint32_t>(MessageQueueFlagBits::NOT_EMPTY)) { in workerCycle()
|