Home
last modified time | relevance | path

Searched refs:mWorkQueue (Results 1 – 16 of 16) sorted by relevance

/frameworks/base/libs/hwui/thread/
DWorkQueue.h67 if (mWorkQueue.empty()) return; in process()
68 toProcess = std::move(mWorkQueue); in process()
72 mWorkQueue.reserve(std::distance(moveBack, std::end(toProcess)) + 5); in process()
73 std::move(moveBack, std::end(toProcess), std::back_inserter(mWorkQueue)); in process()
113 if (mWorkQueue.empty()) { in nextWakeup()
116 return std::begin(mWorkQueue)->runAt; in nextWakeup()
126 std::begin(mWorkQueue), std::end(mWorkQueue), in enqueue()
128 needsWakeup = std::begin(mWorkQueue) == insertAt; in enqueue()
129 mWorkQueue.emplace(insertAt, std::move(item)); in enqueue()
139 std::vector<WorkItem> mWorkQueue; variable
DCommonPool.cpp63 while (!mWorkQueue.hasSpace()) { in enqueue()
68 mWorkQueue.push(std::move(task)); in enqueue()
69 if (mWaitingThreads == THREAD_COUNT || (mWaitingThreads > 0 && mWorkQueue.size() > 1)) { in enqueue()
77 if (!mWorkQueue.hasWork()) { in workerLoop()
84 while (mWorkQueue.hasWork()) { in workerLoop()
85 auto work = mWorkQueue.pop(); in workerLoop()
DCommonPool.h117 ArrayQueue<Task, QUEUE_SIZE> mWorkQueue; variable
/frameworks/opt/gamesdk/samples/bouncyball/app/src/main/cpp/
DWorkerThread.h50 mWorkQueue.emplace(std::move(work)); in run()
92 return !mWorkQueue.empty() || !mIsActive; in threadMain()
94 if (!mWorkQueue.empty()) { in threadMain()
95 auto head = mWorkQueue.front(); in threadMain()
96 mWorkQueue.pop(); in threadMain()
114 std::queue<std::function<void(ThreadState *)>> mWorkQueue GUARDED_BY(mWorkMutex);
/frameworks/av/media/codec2/hidl/1.0/vts/functional/video/
DVtsHalMediaC2V1_0TargetVideoEncTest.cpp75 mWorkQueue.emplace_back(new C2Work); in SetUp()
178 mQueueCondition, mWorkQueue, mEos, mCsd, in handleWorkDone()
213 std::list<std::unique_ptr<C2Work>> mWorkQueue; member in __anona25123500111::Codec2VideoEncHidlTest
428 encodeNFrames(mComponent, mQueueLock, mQueueCondition, mWorkQueue, in TEST_P()
444 waitOnInputConsumption(mQueueLock, mQueueCondition, mWorkQueue, 1)); in TEST_P()
446 testInputBuffer(mComponent, mQueueLock, mWorkQueue, in TEST_P()
455 waitOnInputConsumption(mQueueLock, mQueueCondition, mWorkQueue)); in TEST_P()
490 if (!mWorkQueue.empty()) { in TEST_F()
491 work.swap(mWorkQueue.front()); in TEST_F()
492 mWorkQueue.pop_front(); in TEST_F()
[all …]
DVtsHalMediaC2V1_0TargetVideoDecTest.cpp85 mWorkQueue.emplace_back(new C2Work); in SetUp()
188 mQueueCondition, mWorkQueue, mEos, mCsd, in handleWorkDone()
221 std::list<std::unique_ptr<C2Work>> mWorkQueue; member in __anonf89553e60111::Codec2VideoDecHidlTest
476 mComponent, mQueueLock, mQueueCondition, mWorkQueue, mFlushedIndices, in TEST_P()
483 waitOnInputConsumption(mQueueLock, mQueueCondition, mWorkQueue, 1)); in TEST_P()
485 testInputBuffer(mComponent, mQueueLock, mWorkQueue, in TEST_P()
494 waitOnInputConsumption(mQueueLock, mQueueCondition, mWorkQueue)); in TEST_P()
569 decodeNFrames(mComponent, mQueueLock, mQueueCondition, mWorkQueue, in TEST_F()
583 if (!mWorkQueue.empty()) { in TEST_F()
584 work.swap(mWorkQueue.front()); in TEST_F()
[all …]
/frameworks/av/media/codec2/hidl/1.0/vts/functional/audio/
DVtsHalMediaC2V1_0TargetAudioEncTest.cpp76 mWorkQueue.emplace_back(new C2Work); in SetUp()
135 mQueueCondition, mWorkQueue, mEos, mCsd, in handleWorkDone()
163 std::list<std::unique_ptr<C2Work>> mWorkQueue; member in __anon61905c660111::Codec2AudioEncHidlTest
432 encodeNFrames(mComponent, mQueueLock, mQueueCondition, mWorkQueue, in TEST_P()
440 waitOnInputConsumption(mQueueLock, mQueueCondition, mWorkQueue, 1)); in TEST_P()
442 testInputBuffer(mComponent, mQueueLock, mWorkQueue, in TEST_P()
450 waitOnInputConsumption(mQueueLock, mQueueCondition, mWorkQueue)); in TEST_P()
485 if (!mWorkQueue.empty()) { in TEST_F()
486 work.swap(mWorkQueue.front()); in TEST_F()
487 mWorkQueue.pop_front(); in TEST_F()
[all …]
DVtsHalMediaC2V1_0TargetAudioDecTest.cpp82 mWorkQueue.emplace_back(new C2Work); in SetUp()
174 mQueueCondition, mWorkQueue, mEos, mCsd, in handleWorkDone()
214 std::list<std::unique_ptr<C2Work>> mWorkQueue; member in __anonb7d48cfc0111::Codec2AudioDecHidlTest
563 mComponent, mQueueLock, mQueueCondition, mWorkQueue, mFlushedIndices, in TEST_P()
570 waitOnInputConsumption(mQueueLock, mQueueCondition, mWorkQueue, 1)); in TEST_P()
572 testInputBuffer(mComponent, mQueueLock, mWorkQueue, in TEST_P()
579 waitOnInputConsumption(mQueueLock, mQueueCondition, mWorkQueue)); in TEST_P()
675 mComponent, mQueueLock, mQueueCondition, mWorkQueue, mFlushedIndices, in TEST_F()
678 waitOnInputConsumption(mQueueLock, mQueueCondition, mWorkQueue)); in TEST_F()
694 if (!mWorkQueue.empty()) { in TEST_F()
[all …]
/frameworks/av/media/codec2/components/base/
DSimpleC2Component.cpp238 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in queue_nb()
266 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in flush_sm()
296 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in drain_nb()
340 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in stop()
361 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in reset()
395 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in finish()
420 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in cloneAndSend()
444 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in processQueue()
546 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in processQueue()
/frameworks/av/media/codec2/components/cmds/
Dcodec2.cpp103 std::list<std::unique_ptr<C2Work>> mWorkQueue; member in __anonebcab3d80111::SimplePlayer
227 mWorkQueue.emplace_back(new C2Work); in play()
283 mWorkQueue.push_back(std::move(work)); in play()
332 if (!mWorkQueue.empty()) { in play()
333 work.swap(mWorkQueue.front()); in play()
334 mWorkQueue.pop_front(); in play()
/frameworks/av/media/codec2/hidl/1.0/vts/functional/component/
DVtsHalMediaC2V1_0TargetComponentTest.cpp80 mWorkQueue.emplace_back(new C2Work); in SetUp()
103 mWorkQueue, mEos, mCsd, mFramesReceived); in handleWorkDone()
111 std::list<std::unique_ptr<C2Work>> mWorkQueue; member in __anonf91cb9120111::Codec2ComponentHidlTest
243 mComponent, mQueueLock, mWorkQueue, flags, isNullBuffer)); in TEST_P()
247 waitOnInputConsumption(mQueueLock, mQueueCondition, mWorkQueue)); in TEST_P()
/frameworks/base/tools/aapt/
DWorkQueue.cpp161 Thread(canCallJava), mWorkQueue(workQueue) { in WorkThread()
168 return mWorkQueue->threadLoop(); in threadLoop()
DWorkQueue.h97 WorkQueue* const mWorkQueue; variable
DResourceTable.h130 return mWorkQueue; in getWorkQueue()
638 std::queue<CompileResourceWorkItem> mWorkQueue; variable
DResourceTable.cpp4833 mWorkQueue.push(item); in versionForCompat()
4968 mWorkQueue.push(item); in modifyForCompat()
5242 mWorkQueue.push(workItem); in processBundleFormatImpl()
/frameworks/av/media/codec2/components/base/include/
DSimpleC2Component.h236 Mutexed<WorkQueue> mWorkQueue; variable