Home
last modified time | relevance | path

Searched refs:work_queue (Results 1 – 19 of 19) sorted by relevance

/external/libchrome/base/task/sequence_manager/
Dwork_queue_sets.cc18 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 …]
Dwork_queue_sets_unittest.cc27 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 …]
Dwork_queue_unittest.cc137 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 …]
Dwork_queue_sets.h38 void RemoveQueue(WorkQueue* work_queue);
47 void OnTaskPushedToEmptyQueue(WorkQueue* work_queue);
51 void OnPopQueue(WorkQueue* work_queue);
54 void OnQueueBlocked(WorkQueue* work_queue);
Dsequence_manager_impl.cc322 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/zstd/contrib/pzstd/utils/
DBUCK51 deps=[':work_queue'],
55 name='work_queue',
73 ':work_queue',
/external/llvm-project/llvm/utils/
Dllvm-compilers-check254 def __init__(self, work_queue, jobs, argument
258 self.work_queue = work_queue
273 source, build = self.work_queue.get()
278 self.work_queue.task_done()
594 work_queue = queue.Queue() variable
610 builder = Builder(work_queue, jobs,
618 work_queue.put((source, build))
620 work_queue.join()
/external/llvm/utils/
Dllvm-compilers-check255 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/tensorflow/tensorflow/core/distributed_runtime/
Dcollective_rma_distributed.h31 std::shared_ptr<UnboundedWorkQueue> work_queue, in CollectiveRemoteAccessDistributed() argument
35 work_queue_(std::move(work_queue)), in CollectiveRemoteAccessDistributed()
/external/python/futures/concurrent/futures/
Dthread.py70 def _worker(executor_reference, work_queue): argument
73 work_item = work_queue.get(block=True)
86 work_queue.put(None)
/external/libchrome/base/message_loop/
Dincoming_task_queue.cc296 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()
Dincoming_task_queue.h236 void ReloadWorkQueue(TaskQueue* work_queue);
/external/python/cpython3/Lib/concurrent/futures/
Dthread.py63 def _worker(executor_reference, work_queue, initializer, initargs): argument
75 work_item = work_queue.get(block=True)
99 work_queue.put(None)
/external/tensorflow/tensorflow/core/common_runtime/
Dbase_collective_executor.h101 std::shared_ptr<UnboundedWorkQueue> work_queue) in BaseCollectiveExecutor() argument
107 work_queue_(std::move(work_queue)) {} in BaseCollectiveExecutor()
/external/adhd/cras/src/server/
Dcras_apm_list.c77 void *work_queue; member
319 apm->work_queue = NULL; in cras_apm_list_add_apm()
719 rc = webrtc_apm_aec_dump(apm->apm_ptr, &apm->work_queue, start, in cras_apm_list_set_aec_dump()
725 rc = webrtc_apm_aec_dump(apm->apm_ptr, &apm->work_queue, 0, in cras_apm_list_set_aec_dump()
/external/zstd/contrib/pzstd/utils/test/
DBUCK34 deps=['//contrib/pzstd/utils:work_queue'],
/external/adhd/cras/src/tests/
Dapm_list_unittest.cc432 void** work_queue, in webrtc_apm_aec_dump() argument
/external/openscreen/third_party/chromium_quic/build/base/
DBUILD.gn376 "../../src/base/task/sequence_manager/work_queue.cc",
377 "../../src/base/task/sequence_manager/work_queue.h",
/external/libchrome/
DAndroid.bp363 "base/task/sequence_manager/work_queue.h",