Home
last modified time | relevance | path

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

/aosp12/frameworks/base/libs/hwui/thread/
H A 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
H A DCommonPool.cpp85 while (!mWorkQueue.hasSpace()) { in enqueue()
90 mWorkQueue.push(std::move(task)); in enqueue()
91 if (mWaitingThreads == THREAD_COUNT || (mWaitingThreads > 0 && mWorkQueue.size() > 1)) { in enqueue()
99 if (!mWorkQueue.hasWork()) { in workerLoop()
106 while (mWorkQueue.hasWork()) { in workerLoop()
107 auto work = mWorkQueue.pop(); in workerLoop()
H A DCommonPool.h122 ArrayQueue<Task, QUEUE_SIZE> mWorkQueue; variable
/aosp12/frameworks/native/libs/renderengine/skia/debug/
H A DCommonPool.cpp64 while (mWorkQueue.size() > QUEUE_SIZE) { in enqueue()
70 mWorkQueue.push(std::move(task)); in enqueue()
71 if (mWaitingThreads == THREAD_COUNT || (mWaitingThreads > 0 && mWorkQueue.size() > 1)) { in enqueue()
79 if (mWorkQueue.size() == 0) { in workerLoop()
86 while (mWorkQueue.size() > 0) { in workerLoop()
87 auto work = mWorkQueue.front(); in workerLoop()
88 mWorkQueue.pop(); in workerLoop()
H A DCommonPool.h65 std::queue<Task> mWorkQueue; variable
/aosp12/frameworks/av/media/codec2/hidl/1.0/vts/functional/audio/
H A DVtsHalMediaC2V1_0TargetAudioDecTest.cpp92 mWorkQueue.emplace_back(new C2Work); in SetUp()
201 std::list<std::unique_ptr<C2Work>> mWorkQueue; member in __anon49667b9f0110::Codec2AudioDecHidlTestBase
565 if (!mWorkQueue.empty()) { in TEST_P()
566 work.swap(mWorkQueue.front()); in TEST_P()
567 mWorkQueue.pop_front(); in TEST_P()
587 if (mWorkQueue.size() != MAX_INPUT_BUFFERS) { in TEST_P()
623 ASSERT_EQ(mWorkQueue.size(), MAX_INPUT_BUFFERS); in TEST_P()
640 ASSERT_EQ(mWorkQueue.size(), MAX_INPUT_BUFFERS); in TEST_P()
669 ASSERT_EQ(mWorkQueue.size(), MAX_INPUT_BUFFERS); in TEST_P()
801 ASSERT_EQ(mWorkQueue.size(), MAX_INPUT_BUFFERS); in TEST_P()
[all …]
H A DVtsHalMediaC2V1_0TargetAudioEncTest.cpp65 mWorkQueue.emplace_back(new C2Work); in SetUp()
154 std::list<std::unique_ptr<C2Work>> mWorkQueue; member in __anonf3224b090110::Codec2AudioEncHidlTestBase
496 if (!mWorkQueue.empty()) { in TEST_P()
497 work.swap(mWorkQueue.front()); in TEST_P()
498 mWorkQueue.pop_front(); in TEST_P()
518 queueSize = mWorkQueue.size(); in TEST_P()
551 ASSERT_EQ(mWorkQueue.size(), MAX_INPUT_BUFFERS); in TEST_P()
557 waitOnInputConsumption(mQueueLock, mQueueCondition, mWorkQueue, in TEST_P()
561 ASSERT_EQ(mWorkQueue.size(), MAX_INPUT_BUFFERS); in TEST_P()
569 waitOnInputConsumption(mQueueLock, mQueueCondition, mWorkQueue, in TEST_P()
[all …]
/aosp12/frameworks/av/media/codec2/hidl/1.0/vts/functional/video/
H A DVtsHalMediaC2V1_0TargetVideoDecTest.cpp115 mWorkQueue.emplace_back(new C2Work); in SetUp()
327 std::list<std::unique_ptr<C2Work>> mWorkQueue; member in __anon8a2742890110::Codec2VideoDecHidlTestBase
752 if (!mWorkQueue.empty()) { in TEST_P()
753 work.swap(mWorkQueue.front()); in TEST_P()
754 mWorkQueue.pop_front(); in TEST_P()
835 if (!mWorkQueue.empty()) { in TEST_P()
836 work.swap(mWorkQueue.front()); in TEST_P()
837 mWorkQueue.pop_front(); in TEST_P()
886 ASSERT_EQ(mWorkQueue.size(), MAX_INPUT_BUFFERS); in TEST_P()
905 ASSERT_EQ(mWorkQueue.size(), MAX_INPUT_BUFFERS); in TEST_P()
[all …]
H A DVtsHalMediaC2V1_0TargetVideoEncTest.cpp65 mWorkQueue.emplace_back(new C2Work); in SetUp()
214 std::list<std::unique_ptr<C2Work>> mWorkQueue; member in __anon33e311f30110::Codec2VideoEncHidlTestBase
619 if (!mWorkQueue.empty()) { in TEST_P()
620 work.swap(mWorkQueue.front()); in TEST_P()
621 mWorkQueue.pop_front(); in TEST_P()
641 queueSize = mWorkQueue.size(); in TEST_P()
674 ASSERT_EQ(mWorkQueue.size(), MAX_INPUT_BUFFERS); in TEST_P()
691 waitOnInputConsumption(mQueueLock, mQueueCondition, mWorkQueue, in TEST_P()
695 ASSERT_EQ(mWorkQueue.size(), MAX_INPUT_BUFFERS); in TEST_P()
712 waitOnInputConsumption(mQueueLock, mQueueCondition, mWorkQueue, in TEST_P()
[all …]
/aosp12/frameworks/av/media/tests/benchmark/src/native/common/
H A DBenchmarkC2Common.cpp46 mWorkQueue.emplace_back(new C2Work); in setupCodec2()
77 queueSize = mWorkQueue.size(); in waitOnInputConsumption()
81 if (queueSize != mWorkQueue.size()) { in waitOnInputConsumption()
82 queueSize = mWorkQueue.size(); in waitOnInputConsumption()
106 mWorkQueue.push_back(std::move(work)); in handleWorkDone()
H A DBenchmarkC2Common.h138 std::list<std::unique_ptr<C2Work>> mWorkQueue; variable
/aosp12/frameworks/av/media/codec2/fuzzer/
H A DC2Fuzzer.cpp133 mWorkQueue.push_back(std::move(work)); in handleWorkDone()
176 mWorkQueue.emplace_back(new C2Work); in initDecoder()
259 if (mWorkQueue.empty()) mQueueCondition.wait_for(lock, kC2FuzzerTimeOut); in decodeFrames()
260 if (!mWorkQueue.empty()) { in decodeFrames()
261 work.swap(mWorkQueue.front()); in decodeFrames()
262 mWorkQueue.pop_front(); in decodeFrames()
H A DC2Fuzzer.h118 std::list<std::unique_ptr<C2Work>> mWorkQueue; variable
/aosp12/frameworks/av/media/tests/benchmark/src/native/decoder/
H A DC2Decoder.cpp86 if (mWorkQueue.empty()) mQueueCondition.wait_for(l, MAX_RETRY * TIME_OUT); in decodeFrames()
87 if (!mWorkQueue.empty()) { in decodeFrames()
89 work.swap(mWorkQueue.front()); in decodeFrames()
90 mWorkQueue.pop_front(); in decodeFrames()
/aosp12/frameworks/av/media/codec2/components/base/
H A DSimpleC2Component.cpp241 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in queue_nb()
269 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in flush_sm()
299 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in drain_nb()
343 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in stop()
364 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in reset()
398 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in finish()
423 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in cloneAndSend()
447 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in processQueue()
549 Mutexed<WorkQueue>::Locked queue(mWorkQueue); in processQueue()
/aosp12/frameworks/av/media/codec2/components/cmds/
H A Dcodec2.cpp103 std::list<std::unique_ptr<C2Work>> mWorkQueue; member in __anonb1fe4e5b0110::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()
/aosp12/frameworks/av/media/tests/benchmark/src/native/encoder/
H A DC2Encoder.cpp145 if (mWorkQueue.empty()) mQueueCondition.wait_for(l, MAX_RETRY * TIME_OUT); in encodeFrames()
146 if (!mWorkQueue.empty()) { in encodeFrames()
148 work.swap(mWorkQueue.front()); in encodeFrames()
149 mWorkQueue.pop_front(); in encodeFrames()
/aosp12/frameworks/av/media/codec2/hidl/1.0/vts/functional/component/
H A DVtsHalMediaC2V1_0TargetComponentTest.cpp74 mWorkQueue.emplace_back(new C2Work); in SetUp()
99 workDone(mComponent, work, mFlushedIndices, mQueueLock, mQueueCondition, mWorkQueue, in handleWorkDone()
110 std::list<std::unique_ptr<C2Work>> mWorkQueue; member in __anond54c45950110::Codec2ComponentHidlTestBase
338 testInputBuffer(mComponent, mQueueLock, mWorkQueue, flags, isNullBuffer)); in TEST_P()
341 ASSERT_NO_FATAL_FAILURE(waitOnInputConsumption(mQueueLock, mQueueCondition, mWorkQueue)); in TEST_P()
/aosp12/frameworks/base/tools/aapt/
H A DWorkQueue.cpp161 Thread(canCallJava), mWorkQueue(workQueue) { in WorkThread()
168 return mWorkQueue->threadLoop(); in threadLoop()
H A DWorkQueue.h97 WorkQueue* const mWorkQueue; variable
H A DResourceTable.h130 return mWorkQueue; in getWorkQueue()
638 std::queue<CompileResourceWorkItem> mWorkQueue; variable
H A DResourceTable.cpp4833 mWorkQueue.push(item); in versionForCompat()
4968 mWorkQueue.push(item); in modifyForCompat()
5242 mWorkQueue.push(workItem); in processBundleFormatImpl()
/aosp12/frameworks/av/media/codec2/components/base/include/
H A DSimpleC2Component.h230 Mutexed<WorkQueue> mWorkQueue; variable