/aosp_15_r20/external/libchrome/base/task/sequence_manager/ |
H A D | task_queue_impl.cc | 118 delayed_work_queue( in MainThreadOnly() 174 std::unique_ptr<WorkQueue> delayed_work_queue = in UnregisterTaskQueue() local 175 std::move(main_thread_only().delayed_work_queue); in UnregisterTaskQueue() 357 main_thread_only().delayed_work_queue->InsertFenceSilently( in ReloadEmptyImmediateQueue() 366 if (!main_thread_only().delayed_work_queue->Empty() || in IsEmpty() 378 task_count += main_thread_only().delayed_work_queue->Size(); in GetNumberOfPendingTasks() 389 if (!main_thread_only().delayed_work_queue->Empty() || in HasTaskToRunImmediately() 438 main_thread_only().delayed_work_queue->Push(std::move(task)); in WakeUpForDelayedWork() 470 main_thread_only().delayed_work_queue->Size() + in TraceQueueSize() 484 DCHECK_EQ(set_index, delayed_work_queue()->work_queue_set_index()); in GetQueuePriority() [all …]
|
H A D | task_queue_impl.h | 232 WorkQueue* delayed_work_queue() { in delayed_work_queue() function 233 return main_thread_only().delayed_work_queue.get(); in delayed_work_queue() 236 const WorkQueue* delayed_work_queue() const { in delayed_work_queue() function 237 return main_thread_only().delayed_work_queue.get(); in delayed_work_queue() 350 std::unique_ptr<WorkQueue> delayed_work_queue; member
|
H A D | task_queue_selector.cc | 95 queue->delayed_work_queue()->AssignSetIndex(priority); in SetQueuePriority() 120 delayed_work_queue_sets_.AddQueue(queue->delayed_work_queue(), priority); in AddQueue() 133 delayed_work_queue_sets_.ChangeSetIndex(queue->delayed_work_queue(), in ChangeSetIndex() 147 delayed_work_queue_sets_.RemoveQueue(queue->delayed_work_queue()); in RemoveQueue() 280 queue->delayed_work_queue()); in CheckContainsQueueForTest()
|
H A D | task_queue_selector_unittest.cc | 318 EXPECT_TRUE(task_queues_[2]->delayed_work_queue()->Empty()); in TEST_F() 328 EXPECT_TRUE(task_queues_[2]->delayed_work_queue()->Empty()); in TEST_F() 733 task_queues_[0]->delayed_work_queue()->Push(TaskQueueImpl::Task( in TEST_F() 742 EXPECT_EQ(chosen_work_queue, task_queues_[0]->delayed_work_queue()); in TEST_F() 859 task_queues_[0]->delayed_work_queue()->Push(TaskQueueImpl::Task( in TEST_P()
|
H A D | sequence_manager_impl_unittest.cc | 449 EXPECT_FALSE(runners_[0]->GetTaskQueueImpl()->delayed_work_queue()->Empty()); in TEST_P()
|
/aosp_15_r20/external/cronet/base/task/sequence_manager/ |
H A D | task_queue_impl.cc | 291 delayed_work_queue( in MainThreadOnly() 362 std::unique_ptr<WorkQueue> delayed_work_queue = in UnregisterTaskQueue() local 363 std::move(main_thread_only().delayed_work_queue); in UnregisterTaskQueue() 617 main_thread_only().delayed_work_queue->InsertFenceSilently( in TakeImmediateIncomingQueueTasks() 628 if (!main_thread_only().delayed_work_queue->Empty() || in IsEmpty() 640 task_count += main_thread_only().delayed_work_queue->Size(); in GetNumberOfPendingTasks() 651 if (!main_thread_only().delayed_work_queue->Empty() || in HasTaskToRunImmediatelyOrReadyDelayedTask() 729 main_thread_only().delayed_work_queue->CreateTaskPusher()); in MoveReadyDelayedTasksToWorkQueue() 788 main_thread_only().delayed_work_queue->Size() + in TraceQueueSize() 828 DCHECK_EQ(set_index, delayed_work_queue()->work_queue_set_index()); in GetQueuePriority() [all …]
|
H A D | task_queue_selector_unittest.cc | 284 EXPECT_TRUE(task_queues_[2]->delayed_work_queue()->Empty()); in TEST_F() 293 EXPECT_TRUE(task_queues_[2]->delayed_work_queue()->Empty()); in TEST_F() 405 task_queues_[0]->delayed_work_queue()->Push( in TEST_F() 410 task_queues_[0]->delayed_work_queue(), in TEST_F() 430 task_queues_[0]->delayed_work_queue()->Push( in TEST_F() 437 EXPECT_EQ(task_queues_[0]->delayed_work_queue(), in TEST_F() 443 task_queues_[0]->delayed_work_queue()->Push( in TEST_F() 453 EXPECT_EQ(task_queues_[0]->delayed_work_queue(), in TEST_F() 459 task_queues_[0]->delayed_work_queue()->Push( in TEST_F() 465 task_queues_[1]->delayed_work_queue()->Push( in TEST_F() [all …]
|
H A D | task_queue_selector.cc | 84 queue->delayed_work_queue()->AssignSetIndex(priority); in SetQueuePriority() 95 delayed_work_queue_sets_.AddQueue(queue->delayed_work_queue(), priority); in AddQueueImpl() 107 delayed_work_queue_sets_.ChangeSetIndex(queue->delayed_work_queue(), in ChangeSetIndex() 120 delayed_work_queue_sets_.RemoveQueue(queue->delayed_work_queue()); in RemoveQueueImpl() 171 queue->delayed_work_queue()); in CheckContainsQueueForTest()
|
H A D | task_queue_impl.h | 190 WorkQueue* delayed_work_queue() { in delayed_work_queue() function 191 return main_thread_only().delayed_work_queue.get(); in delayed_work_queue() 194 const WorkQueue* delayed_work_queue() const { in delayed_work_queue() function 195 return main_thread_only().delayed_work_queue.get(); in delayed_work_queue() 421 std::unique_ptr<WorkQueue> delayed_work_queue; member
|
H A D | sequence_manager_impl.cc | 124 if (queue->delayed_work_queue()) { in ReclaimMemoryFromQueue() 125 queue->delayed_work_queue()->RemoveAllCanceledTasksFromFront(); in ReclaimMemoryFromQueue() 1120 queue->delayed_work_queue()->RemoveAllCanceledTasksFromFront(); in IsIdleForTesting()
|
H A D | README.md | 59 `main_thread_only().delayed_work_queue` and follows the regular work queue
|
H A D | sequence_manager_impl_unittest.cc | 981 EXPECT_FALSE(GetTaskQueueImpl(queue.get())->delayed_work_queue()->Empty()); in TEST_P() 986 EXPECT_TRUE(GetTaskQueueImpl(queue.get())->delayed_work_queue()->Empty()); in TEST_P()
|
/aosp_15_r20/out/soong/.intermediates/external/libchrome/libchrome-include/gen/gensrcs/external/libchrome/base/task/sequence_manager/ |
D | task_queue_impl.h | 235 WorkQueue* delayed_work_queue() { in delayed_work_queue() function 236 return main_thread_only().delayed_work_queue.get(); in delayed_work_queue() 239 const WorkQueue* delayed_work_queue() const { in delayed_work_queue() function 240 return main_thread_only().delayed_work_queue.get(); in delayed_work_queue() 353 std::unique_ptr<WorkQueue> delayed_work_queue; member
|
/aosp_15_r20/out/soong/.intermediates/external/libchrome/libchrome-include/gen/5/external/libchrome/base/task/sequence_manager/ |
D | task_queue_impl.h | 235 WorkQueue* delayed_work_queue() { in delayed_work_queue() function 236 return main_thread_only().delayed_work_queue.get(); in delayed_work_queue() 239 const WorkQueue* delayed_work_queue() const { in delayed_work_queue() function 240 return main_thread_only().delayed_work_queue.get(); in delayed_work_queue() 353 std::unique_ptr<WorkQueue> delayed_work_queue; member
|