Home
last modified time | relevance | path

Searched refs:WorkQueue (Results 1 – 20 of 20) sorted by relevance

/external/libchrome/base/task/sequence_manager/
Dwork_queue_sets_unittest.cc27 for (std::unique_ptr<WorkQueue>& work_queue : work_queues_) { in TearDown()
38 WorkQueue* NewTaskQueue(const char* queue_name) { in NewTaskQueue()
39 WorkQueue* queue = in NewTaskQueue()
40 new WorkQueue(nullptr, "test", WorkQueue::QueueType::kImmediate); in NewTaskQueue()
61 std::vector<std::unique_ptr<WorkQueue>> work_queues_;
66 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F()
74 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F()
78 WorkQueue* selected_work_queue; in TEST_F()
84 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F()
88 WorkQueue* selected_work_queue; in TEST_F()
[all …]
Dwork_queue.cc13 WorkQueue::WorkQueue(TaskQueueImpl* task_queue, in WorkQueue() function in base::sequence_manager::internal::WorkQueue
18 void WorkQueue::AsValueInto(TimeTicks now, in AsValueInto()
25 WorkQueue::~WorkQueue() { in ~WorkQueue()
30 const TaskQueueImpl::Task* WorkQueue::GetFrontTask() const { in GetFrontTask()
36 const TaskQueueImpl::Task* WorkQueue::GetBackTask() const { in GetBackTask()
42 bool WorkQueue::BlockedByFence() const { in BlockedByFence()
52 bool WorkQueue::GetFrontTaskEnqueueOrder(EnqueueOrder* enqueue_order) const { in GetFrontTaskEnqueueOrder()
63 void WorkQueue::Push(TaskQueueImpl::Task task) { in Push()
83 void WorkQueue::PushNonNestableTaskToFront(TaskQueueImpl::Task task) { in PushNonNestableTaskToFront()
117 void WorkQueue::ReloadEmptyImmediateQueue() { in ReloadEmptyImmediateQueue()
[all …]
Dwork_queue_sets.h35 void AddQueue(WorkQueue* queue, size_t set_index);
38 void RemoveQueue(WorkQueue* work_queue);
41 void ChangeSetIndex(WorkQueue* queue, size_t set_index);
44 void OnFrontTaskChanged(WorkQueue* queue);
47 void OnTaskPushedToEmptyQueue(WorkQueue* work_queue);
51 void OnPopQueue(WorkQueue* work_queue);
54 void OnQueueBlocked(WorkQueue* work_queue);
57 bool GetOldestQueueInSet(size_t set_index, WorkQueue** out_work_queue) const;
62 WorkQueue** out_work_queue,
71 bool ContainsWorkQueueForTest(const WorkQueue* queue) const;
[all …]
Dwork_queue_sets.cc18 void WorkQueueSets::AddQueue(WorkQueue* work_queue, size_t set_index) { in AddQueue()
30 void WorkQueueSets::RemoveQueue(WorkQueue* work_queue) { in RemoveQueue()
41 void WorkQueueSets::ChangeSetIndex(WorkQueue* work_queue, size_t set_index) { in ChangeSetIndex()
56 void WorkQueueSets::OnFrontTaskChanged(WorkQueue* work_queue) { in OnFrontTaskChanged()
65 void WorkQueueSets::OnTaskPushedToEmptyQueue(WorkQueue* work_queue) { in OnTaskPushedToEmptyQueue()
80 void WorkQueueSets::OnPopQueue(WorkQueue* work_queue) { in OnPopQueue()
101 void WorkQueueSets::OnQueueBlocked(WorkQueue* work_queue) { in OnQueueBlocked()
112 WorkQueue** out_work_queue) const { in GetOldestQueueInSet()
124 WorkQueue** out_work_queue, in GetOldestQueueAndEnqueueOrderInSet()
146 const WorkQueue* work_queue) const { in ContainsWorkQueueForTest()
Dtask_queue_selector.h52 bool SelectWorkQueueToService(WorkQueue** out_work_queue);
86 WorkQueue** out_work_queue,
105 WorkQueue** out_work_queue) const;
114 WorkQueue** out_work_queue) const;
117 WorkQueue** out_work_queue) const;
127 WorkQueue** out_work_queue) const;
199 bool SelectWorkQueueToServiceInternal(WorkQueue** out_work_queue);
Dwork_queue.h31 class BASE_EXPORT WorkQueue {
36 WorkQueue(TaskQueueImpl* task_queue, const char* name, QueueType queue_type);
37 ~WorkQueue();
106 bool ShouldRunBefore(const WorkQueue* other_queue) const;
145 DISALLOW_COPY_AND_ASSIGN(WorkQueue);
Dtask_queue_selector_unittest.cc134 WorkQueue* chosen_work_queue; in PopTasks()
337 WorkQueue* chosen_work_queue = nullptr; in TEST_F()
371 WorkQueue* chosen_work_queue = nullptr; in TEST_F()
387 WorkQueue* chosen_work_queue = nullptr; in TEST_F()
407 WorkQueue* chosen_work_queue = nullptr; in TEST_F()
436 WorkQueue* chosen_work_queue = nullptr; in TEST_F()
465 WorkQueue* chosen_work_queue = nullptr; in TEST_F()
488 WorkQueue* chosen_work_queue = nullptr; in TEST_F()
514 WorkQueue* chosen_work_queue = nullptr; in TEST_F()
534 WorkQueue* chosen_work_queue = nullptr; in TEST_F()
[all …]
Dwork_queue_unittest.cc41 work_queue_.reset(new WorkQueue(task_queue_.get(), "test", in SetUp()
42 WorkQueue::QueueType::kImmediate)); in SetUp()
78 std::unique_ptr<WorkQueue> work_queue_;
137 WorkQueue* work_queue; in TEST_F()
147 WorkQueue* work_queue; in TEST_F()
155 WorkQueue* work_queue; in TEST_F()
172 WorkQueue* work_queue; in TEST_F()
182 WorkQueue* work_queue; in TEST_F()
195 WorkQueue* work_queue; in TEST_F()
216 WorkQueue* work_queue; in TEST_F()
[all …]
Dtask_queue_impl.h37 class WorkQueue; variable
232 WorkQueue* delayed_work_queue() { in delayed_work_queue()
236 const WorkQueue* delayed_work_queue() const { in delayed_work_queue()
240 WorkQueue* immediate_work_queue() { in immediate_work_queue()
244 const WorkQueue* immediate_work_queue() const { in immediate_work_queue()
319 friend class WorkQueue;
350 std::unique_ptr<WorkQueue> delayed_work_queue;
351 std::unique_ptr<WorkQueue> immediate_work_queue;
Dtask_queue_selector.cc157 WorkQueue** out_work_queue) const { in ChooseOldestImmediateTaskWithPriority()
164 WorkQueue** out_work_queue) const { in ChooseOldestDelayedTaskWithPriority()
172 WorkQueue** out_work_queue) const { in ChooseOldestImmediateOrDelayedTaskWithPriority()
173 WorkQueue* immediate_queue; in ChooseOldestImmediateOrDelayedTaskWithPriority()
178 WorkQueue* delayed_queue; in ChooseOldestImmediateOrDelayedTaskWithPriority()
199 WorkQueue** out_work_queue) const { in ChooseOldestWithPriority()
213 WorkQueue** out_work_queue, in SelectWorkQueueToService()
291 bool TaskQueueSelector::SelectWorkQueueToService(WorkQueue** out_work_queue) { in SelectWorkQueueToService()
Dtask_queue_impl.cc119 new WorkQueue(task_queue, "delayed", WorkQueue::QueueType::kDelayed)), in MainThreadOnly()
120 immediate_work_queue(new WorkQueue(task_queue, in MainThreadOnly()
122 WorkQueue::QueueType::kImmediate)), in MainThreadOnly()
172 std::unique_ptr<WorkQueue> immediate_work_queue = in UnregisterTaskQueue()
174 std::unique_ptr<WorkQueue> delayed_work_queue = in UnregisterTaskQueue()
Dsequence_manager_impl.h259 internal::WorkQueue* selected_work_queue) const;
Dsequence_manager_impl.cc322 internal::WorkQueue* work_queue = nullptr; in TakeTask()
577 internal::WorkQueue* selected_work_queue) const { in AsValueWithSelectorResult()
/external/libchrome/base/synchronization/
Dcondition_variable_unittest.cc69 class WorkQueue : public PlatformThread::Delegate { class
71 explicit WorkQueue(int thread_count);
72 ~WorkQueue() override;
259 WorkQueue queue(kThreadCount); // Start the threads. in TEST_F()
409 WorkQueue queue(kThreadCount); // Start the threads. in TEST_F()
502 WorkQueue::WorkQueue(int thread_count) in WorkQueue() function in base::__anon8ac0f38a0111::WorkQueue
529 WorkQueue::~WorkQueue() { in ~WorkQueue()
542 int WorkQueue::GetThreadId() { in GetThreadId()
548 bool WorkQueue::EveryIdWasAllocated() const { in EveryIdWasAllocated()
553 TimeDelta WorkQueue::GetAnAssignment(int thread_id) { in GetAnAssignment()
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/
DWorkQueueTest.kt28 val queue = WorkQueue() in testLastScheduledComesFirst()
36 val queue = WorkQueue() in testWorkOffload()
48 val queue = WorkQueue() in testWorkOffloadPrecision()
58 val victim = WorkQueue() in testTimelyStealing()
66 val stealer = WorkQueue() in testTimelyStealing()
82 val victim = WorkQueue() in testStealingBySize()
86 val stealer = WorkQueue() in testStealingBySize()
107 val victim = WorkQueue() in testStealingFromHead()
113 val stealer = WorkQueue() in testStealingFromHead()
135 internal fun WorkQueue.drain(): List<Long> { in drain()
DWorkQueueStressTest.kt22 private val producerQueue = WorkQueue()
56 val myQueue = WorkQueue() in testStealing()
91 val myQueue = WorkQueue() in testSingleProducerSingleStealer()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/scheduling/
DWorkQueue.kt36 internal class WorkQueue { in <lambda>() class
99 fun trySteal(victim: WorkQueue, globalQueue: GlobalQueue): Boolean { in <lambda>()
121 victim: WorkQueue, in <lambda>()
DCoroutineScheduler.kt622 val localQueue: WorkQueue = WorkQueue() in <lambda>()
/external/swiftshader/third_party/llvm-7.0/llvm/lib/Transforms/Scalar/
DEarlyCSE.cpp614 SmallVector<MemoryAccess *, 8> WorkQueue; in removeMSSA() local
615 WorkQueue.push_back(MA); in removeMSSA()
619 for (unsigned I = 0; I < WorkQueue.size(); ++I) { in removeMSSA()
620 MemoryAccess *WI = WorkQueue[I]; in removeMSSA()
632 WorkQueue.push_back(MP); in removeMSSA()
/external/cpuinfo/test/dmesg/
Dmeizu-pro-7-plus.log3511 [ 4.665437] (8)[346:teei_daemon]BOOTPROF: 4665.437703:TEEI WorkQueue Created