| /external/libchrome/base/task/sequence_manager/ |
| D | work_queue_sets.cc | 18 void WorkQueueSets::AddQueue(WorkQueue* work_queue, size_t set_index) { in AddQueue() argument
19 DCHECK(!work_queue->work_queue_sets()); in AddQueue()
22 bool has_enqueue_order = work_queue->GetFrontTaskEnqueueOrder(&enqueue_order); in AddQueue()
23 work_queue->AssignToWorkQueueSets(this); in AddQueue()
24 work_queue->AssignSetIndex(set_index); in AddQueue()
27 work_queue_heaps_[set_index].insert({enqueue_order, work_queue}); in AddQueue()
30 void WorkQueueSets::RemoveQueue(WorkQueue* work_queue) { in RemoveQueue() argument
31 DCHECK_EQ(this, work_queue->work_queue_sets()); in RemoveQueue()
32 work_queue->AssignToWorkQueueSets(nullptr); in RemoveQueue()
33 HeapHandle heap_handle = work_queue->heap_handle(); in RemoveQueue()
[all …]
|
| D | work_queue_sets_unittest.cc | 27 for (std::unique_ptr<WorkQueue>& work_queue : work_queues_) { in TearDown()
28 if (work_queue->work_queue_sets()) in TearDown()
29 work_queue_sets_->RemoveQueue(work_queue.get()); in TearDown()
66 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
68 work_queue_sets_->ChangeSetIndex(work_queue, set); in TEST_F()
70 EXPECT_EQ(set, work_queue->work_queue_set_index()); in TEST_F()
74 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
76 work_queue_sets_->ChangeSetIndex(work_queue, set); in TEST_F()
84 WorkQueue* work_queue = NewTaskQueue("queue"); in TEST_F() local
86 work_queue_sets_->ChangeSetIndex(work_queue, set); in TEST_F()
[all …]
|
| D | work_queue_unittest.cc | 137 WorkQueue* work_queue; in TEST_F() local
138 EXPECT_FALSE(work_queue_sets_->GetOldestQueueInSet(0, &work_queue)); in TEST_F()
141 EXPECT_TRUE(work_queue_sets_->GetOldestQueueInSet(0, &work_queue)); in TEST_F()
142 EXPECT_EQ(work_queue_.get(), work_queue); in TEST_F()
147 WorkQueue* work_queue; in TEST_F() local
148 EXPECT_FALSE(work_queue_sets_->GetOldestQueueInSet(0, &work_queue)); in TEST_F()
151 EXPECT_FALSE(work_queue_sets_->GetOldestQueueInSet(0, &work_queue)); in TEST_F()
155 WorkQueue* work_queue; in TEST_F() local
156 EXPECT_FALSE(work_queue_sets_->GetOldestQueueInSet(0, &work_queue)); in TEST_F()
160 EXPECT_TRUE(work_queue_sets_->GetOldestQueueInSet(0, &work_queue)); in TEST_F()
[all …]
|
| D | work_queue_sets.h | 38 void RemoveQueue(WorkQueue* work_queue);
47 void OnTaskPushedToEmptyQueue(WorkQueue* work_queue);
51 void OnPopQueue(WorkQueue* work_queue);
54 void OnQueueBlocked(WorkQueue* work_queue);
|
| D | sequence_manager_impl.cc | 322 internal::WorkQueue* work_queue = nullptr; in TakeTask() local
324 main_thread_only().selector.SelectWorkQueueToService(&work_queue); in TakeTask()
327 this, AsValueWithSelectorResult(should_run, work_queue)); in TakeTask()
333 if (work_queue->RemoveAllCanceledTasksFromFront()) in TakeTask()
336 if (work_queue->GetFrontTask()->nestable == Nestable::kNonNestable && in TakeTask()
343 work_queue->TakeTaskFromWorkQueue(), work_queue->task_queue(), in TakeTask()
344 work_queue->queue_type()}; in TakeTask()
351 work_queue->TakeTaskFromWorkQueue(), work_queue->task_queue(), in TakeTask()
352 InitializeTaskTiming(work_queue->task_queue())); in TakeTask()
|
| /external/v8/tools/testrunner/local/ |
| D | pool.py | 55 def Worker(fn, work_queue, done_queue, argument
64 for args in iter(work_queue.get, "STOP"):
123 self.work_queue = Queue()
155 self.work_queue,
198 self.work_queue.put(gen.next())
212 self.work_queue.put(args)
236 self.work_queue.get(True, 0.1)
244 self.work_queue.put("STOP")
256 while True: self.work_queue.get(False)
|
| /external/llvm/utils/ |
| D | llvm-compilers-check | 255 def __init__(self, work_queue, jobs, argument
259 self.work_queue = work_queue
274 source, build = self.work_queue.get()
279 self.work_queue.task_done()
595 work_queue = queue.Queue() variable
611 builder = Builder(work_queue, jobs,
619 work_queue.put((source, build))
621 work_queue.join()
|
| /external/swiftshader/third_party/llvm-7.0/llvm/utils/ |
| D | llvm-compilers-check | 255 def __init__(self, work_queue, jobs, argument
259 self.work_queue = work_queue
274 source, build = self.work_queue.get()
279 self.work_queue.task_done()
595 work_queue = queue.Queue() variable
611 builder = Builder(work_queue, jobs,
619 work_queue.put((source, build))
621 work_queue.join()
|
| /external/swiftshader/third_party/LLVM/utils/ |
| D | llvmbuild | 300 def __init__(self, work_queue, jobs,
304 self.work_queue = work_queue
323 source, branch, build = self.work_queue.get()
328 self.work_queue.task_done()
751 work_queue = queue.Queue()
764 builder = Builder(work_queue, jobs,
774 work_queue.put((source, branch, build))
776 work_queue.put((source, None, build))
778 work_queue.join()
|
| /external/libchrome/base/message_loop/ |
| D | incoming_task_queue.cc | 296 void IncomingTaskQueue::ReloadWorkQueue(TaskQueue* work_queue) { in ReloadWorkQueue() argument
300 DCHECK(work_queue->empty()); in ReloadWorkQueue()
304 incoming_queue_.swap(*work_queue); in ReloadWorkQueue()
305 triage_queue_empty_ = work_queue->empty(); in ReloadWorkQueue()
|
| D | incoming_task_queue.h | 236 void ReloadWorkQueue(TaskQueue* work_queue);
|
| /external/python/futures/concurrent/futures/ |
| D | thread.py | 70 def _worker(executor_reference, work_queue): argument
73 work_item = work_queue.get(block=True)
86 work_queue.put(None)
|
| /external/python/cpython3/Lib/concurrent/futures/ |
| D | thread.py | 66 def _worker(executor_reference, work_queue, initializer, initargs): argument
78 work_item = work_queue.get(block=True)
95 work_queue.put(None)
|
| /external/adhd/cras/src/server/ |
| D | cras_apm_list.c | 71 void *work_queue; member
281 apm->work_queue = NULL; in cras_apm_list_add()
632 rc = webrtc_apm_aec_dump(apm->apm_ptr, &apm->work_queue, start, in cras_apm_list_set_aec_dump()
638 rc = webrtc_apm_aec_dump(apm->apm_ptr, &apm->work_queue, 0, in cras_apm_list_set_aec_dump()
|
| /external/adhd/cras/src/tests/ |
| D | apm_list_unittest.cc | 258 int webrtc_apm_aec_dump(webrtc_apm ptr, void** work_queue, in webrtc_apm_aec_dump() argument
|