| /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
|