/external/libchrome/base/task/sequence_manager/ |
D | task_queue_impl.cc | 43 TaskQueueImpl::TaskQueueImpl(SequenceManagerImpl* sequence_manager, in TaskQueueImpl() function in base::sequence_manager::internal::TaskQueueImpl 55 TaskQueueImpl::~TaskQueueImpl() { in ~TaskQueueImpl() 67 TaskQueueImpl::PostTaskResult::PostTaskResult() in PostTaskResult() 70 TaskQueueImpl::PostTaskResult::PostTaskResult(bool success, in PostTaskResult() 74 TaskQueueImpl::PostTaskResult::PostTaskResult(PostTaskResult&& move_from) in PostTaskResult() 77 TaskQueueImpl::PostTaskResult::~PostTaskResult() = default; 79 TaskQueueImpl::PostTaskResult TaskQueueImpl::PostTaskResult::Success() { in Success() 83 TaskQueueImpl::PostTaskResult TaskQueueImpl::PostTaskResult::Fail( in Fail() 88 TaskQueueImpl::Task::Task(TaskQueue::PostedTask task, in Task() 96 TaskQueueImpl::Task::Task(TaskQueue::PostedTask task, in Task() [all …]
|
D | sequence_manager_impl.h | 57 class TaskQueueImpl; variable 129 internal::TaskQueueImpl* currently_executing_task_queue() const; 134 std::unique_ptr<internal::TaskQueueImpl> task_queue); 147 friend class internal::TaskQueueImpl; 168 circular_deque<internal::TaskQueueImpl::DeferredNonNestableTask>; 174 ExecutingTask(internal::TaskQueueImpl::Task&& pending_task, in ExecutingTask() 175 internal::TaskQueueImpl* task_queue, in ExecutingTask() 181 internal::TaskQueueImpl::Task pending_task; 182 internal::TaskQueueImpl* task_queue = nullptr; 216 std::set<internal::TaskQueueImpl*> active_queues; [all …]
|
D | work_queue.h | 33 using QueueType = internal::TaskQueueImpl::WorkQueueType; 36 WorkQueue(TaskQueueImpl* task_queue, const char* name, QueueType queue_type); 58 const TaskQueueImpl::Task* GetFrontTask() const; 62 const TaskQueueImpl::Task* GetBackTask() const; 66 void Push(TaskQueueImpl::Task task); 71 void PushNonNestableTaskToFront(TaskQueueImpl::Task task); 83 TaskQueueImpl::Task TakeTaskFromWorkQueue(); 91 TaskQueueImpl* task_queue() const { return task_queue_; } in task_queue() 136 TaskQueueImpl::TaskDeque tasks_; 138 TaskQueueImpl* const task_queue_; // NOT OWNED.
|
D | task_queue_selector.h | 30 void AddQueue(internal::TaskQueueImpl* queue); 34 void RemoveQueue(internal::TaskQueueImpl* queue); 38 void EnableQueue(internal::TaskQueueImpl* queue); 41 void DisableQueue(internal::TaskQueueImpl* queue); 44 void SetQueuePriority(internal::TaskQueueImpl* queue, 62 virtual void OnTaskQueueEnabled(internal::TaskQueueImpl* queue) = 0; 79 void ChangeSetIndex(internal::TaskQueueImpl* queue, 81 void AddQueue(internal::TaskQueueImpl* queue, 83 void RemoveQueue(internal::TaskQueueImpl* queue); 108 bool CheckContainsQueueForTest(const internal::TaskQueueImpl* queue) const;
|
D | time_domain_unittest.cc | 23 class TaskQueueImplForTest : public internal::TaskQueueImpl { 28 : TaskQueueImpl(sequence_manager, time_domain, spec) {} in TaskQueueImplForTest() 31 using TaskQueueImpl::SetDelayedWakeUpForTesting; 55 internal::TaskQueueImpl* NextScheduledTaskQueue() const { in NextScheduledTaskQueue() 100 internal::TaskQueueImpl::DelayedWakeUp{now + delay, 0}); in TEST_F() 120 internal::TaskQueueImpl::DelayedWakeUp{delayed_runtime1, 0}); in TEST_F() 130 internal::TaskQueueImpl::DelayedWakeUp{delayed_runtime2, 0}); in TEST_F() 163 internal::TaskQueueImpl::DelayedWakeUp{now + delay1, 0}); in TEST_F() 170 internal::TaskQueueImpl::DelayedWakeUp{now + delay2, 0}); in TEST_F() 172 internal::TaskQueueImpl::DelayedWakeUp{now + delay3, 0}); in TEST_F() [all …]
|
D | time_domain.h | 25 class TaskQueueImpl; variable 86 friend class internal::TaskQueueImpl; 100 internal::TaskQueueImpl* queue, 101 Optional<internal::TaskQueueImpl::DelayedWakeUp> wake_up, 105 void UnregisterQueue(internal::TaskQueueImpl* queue); 111 internal::TaskQueueImpl::DelayedWakeUp wake_up; 112 internal::TaskQueueImpl* queue;
|
D | task_queue_impl.h | 42 TaskQueueImpl* queue = nullptr; 72 class BASE_EXPORT TaskQueueImpl { 74 TaskQueueImpl(SequenceManagerImpl* sequence_manager, 78 ~TaskQueueImpl(); 169 internal::TaskQueueImpl::Task task; 170 internal::TaskQueueImpl* task_queue; 269 void PushImmediateIncomingTaskForTest(TaskQueueImpl::Task&& task); 279 TaskQueueImpl* GetTaskQueueForTest() const { in GetTaskQueueForTest() 284 friend class TaskQueueImpl; 338 TaskQueueImpl* task_queue, [all …]
|
D | work_queue.cc | 13 WorkQueue::WorkQueue(TaskQueueImpl* task_queue, in WorkQueue() 20 for (const TaskQueueImpl::Task& task : tasks_) { in AsValueInto() 21 TaskQueueImpl::TaskAsValueInto(task, now, state); in AsValueInto() 30 const TaskQueueImpl::Task* WorkQueue::GetFrontTask() const { in GetFrontTask() 36 const TaskQueueImpl::Task* WorkQueue::GetBackTask() const { in GetBackTask() 63 void WorkQueue::Push(TaskQueueImpl::Task task) { in Push() 83 void WorkQueue::PushNonNestableTaskToFront(TaskQueueImpl::Task task) { in PushNonNestableTaskToFront() 129 TaskQueueImpl::Task WorkQueue::TakeTaskFromWorkQueue() { in TakeTaskFromWorkQueue() 133 TaskQueueImpl::Task pending_task = std::move(tasks_.front()); in TakeTaskFromWorkQueue()
|
D | sequence_manager_impl.cc | 51 internal::TaskQueueImpl* queue, in SweepCanceledDelayedTasksInQueue() 103 for (internal::TaskQueueImpl* queue : main_thread_only().active_queues) { in ~SequenceManagerImpl() 149 std::unique_ptr<internal::TaskQueueImpl> 157 std::unique_ptr<internal::TaskQueueImpl> task_queue = in CreateTaskQueueImpl() 158 std::make_unique<internal::TaskQueueImpl>(this, time_domain, spec); in CreateTaskQueueImpl() 169 internal::TaskQueueImpl* task_queue, in AddToIncomingImmediateWorkList() 187 internal::TaskQueueImpl* task_queue) { in RemoveFromIncomingImmediateWorkList() 204 std::unique_ptr<internal::TaskQueueImpl> task_queue) { in UnregisterTaskQueueImpl() 233 for (internal::TaskQueueImpl* queue : main_thread_only().queues_to_reload) { in ReloadEmptyWorkQueues() 266 internal::TaskQueueImpl::DeferredNonNestableTask& non_nestable_task = in OnExitNestedRunLoop() [all …]
|
D | graceful_queue_shutdown_helper.h | 19 class TaskQueueImpl; variable 28 std::unique_ptr<internal::TaskQueueImpl> queue); 32 std::vector<std::unique_ptr<internal::TaskQueueImpl>> TakeQueues(); 41 std::vector<std::unique_ptr<internal::TaskQueueImpl>> queues_;
|
D | task_queue_selector_unittest.cc | 36 MOCK_METHOD1(OnTaskQueueEnabled, void(internal::TaskQueueImpl*)); 112 TaskQueueImpl::Task(TaskQueue::PostedTask(test_closure_, FROM_HERE), in PushTasks() 125 TaskQueueImpl::Task( in PushTasksWithEnqueueOrder() 152 std::unique_ptr<TaskQueueImpl> task_queue = in SetUp() 153 std::make_unique<TaskQueueImpl>(nullptr, time_domain_.get(), in SetUp() 167 for (std::unique_ptr<TaskQueueImpl>& task_queue : task_queues_) { in TearDown() 176 std::unique_ptr<TaskQueueImpl> NewTaskQueueWithBlockReporting() { in NewTaskQueueWithBlockReporting() 177 return std::make_unique<TaskQueueImpl>(nullptr, time_domain_.get(), in NewTaskQueueWithBlockReporting() 185 std::vector<std::unique_ptr<TaskQueueImpl>> task_queues_; 186 std::map<TaskQueueImpl*, size_t> queue_to_index_map_; [all …]
|
D | task_queue_selector.cc | 59 void TaskQueueSelector::AddQueue(internal::TaskQueueImpl* queue) { in AddQueue() 65 void TaskQueueSelector::RemoveQueue(internal::TaskQueueImpl* queue) { in RemoveQueue() 72 void TaskQueueSelector::EnableQueue(internal::TaskQueueImpl* queue) { in EnableQueue() 80 void TaskQueueSelector::DisableQueue(internal::TaskQueueImpl* queue) { in DisableQueue() 86 void TaskQueueSelector::SetQueuePriority(internal::TaskQueueImpl* queue, in SetQueuePriority() 115 internal::TaskQueueImpl* queue, in AddQueue() 128 internal::TaskQueueImpl* queue, in ChangeSetIndex() 143 internal::TaskQueueImpl* queue) { in RemoveQueue() 277 const internal::TaskQueueImpl* queue) const { in CheckContainsQueueForTest()
|
D | task_queue.h | 30 class TaskQueueImpl; variable 325 TaskQueue(std::unique_ptr<internal::TaskQueueImpl> impl, 329 internal::TaskQueueImpl* GetTaskQueueImpl() const { return impl_.get(); } in GetTaskQueueImpl() 333 friend class internal::TaskQueueImpl; 343 std::unique_ptr<internal::TaskQueueImpl> TakeTaskQueueImpl(); 351 std::unique_ptr<internal::TaskQueueImpl> impl_;
|
D | graceful_queue_shutdown_helper.cc | 19 std::unique_ptr<internal::TaskQueueImpl> task_queue) { in GracefullyShutdownTaskQueue() 32 std::vector<std::unique_ptr<internal::TaskQueueImpl>> 35 std::vector<std::unique_ptr<internal::TaskQueueImpl>> result; in TakeQueues()
|
D | time_domain.cc | 44 void TimeDomain::UnregisterQueue(internal::TaskQueueImpl* queue) { in UnregisterQueue() 52 internal::TaskQueueImpl* queue, in SetNextWakeUpForQueue() 53 Optional<internal::TaskQueueImpl::DelayedWakeUp> wake_up, in SetNextWakeUpForQueue() 107 internal::TaskQueueImpl* queue = delayed_wake_up_queue_.Min().queue; in WakeUpReadyDelayedQueues()
|
D | work_queue_unittest.cc | 38 task_queue_ = std::make_unique<TaskQueueImpl>(nullptr, time_domain_.get(), in SetUp() 50 TaskQueueImpl::Task FakeCancelableTaskWithEnqueueOrder( in FakeCancelableTaskWithEnqueueOrder() 53 TaskQueueImpl::Task fake_task( in FakeCancelableTaskWithEnqueueOrder() 61 TaskQueueImpl::Task FakeTaskWithEnqueueOrder(int enqueue_order) { in FakeTaskWithEnqueueOrder() 62 TaskQueueImpl::Task fake_task( in FakeTaskWithEnqueueOrder() 68 TaskQueueImpl::Task FakeNonNestableTaskWithEnqueueOrder(int enqueue_order) { in FakeNonNestableTaskWithEnqueueOrder() 69 TaskQueueImpl::Task fake_task( in FakeNonNestableTaskWithEnqueueOrder() 77 std::unique_ptr<TaskQueueImpl> task_queue_; 80 std::unique_ptr<TaskQueueImpl::TaskDeque> incoming_queue_;
|
D | task_queue.cc | 15 TaskQueue::TaskQueue(std::unique_ptr<internal::TaskQueueImpl> impl, in TaskQueue() 88 internal::TaskQueueImpl::OnTaskStartedHandler()); in ShutdownTaskQueue() 90 internal::TaskQueueImpl::OnTaskCompletedHandler()); in ShutdownTaskQueue() 116 internal::TaskQueueImpl::PostTaskResult result( in PostTaskWithMetadata() 283 std::unique_ptr<internal::TaskQueueImpl> TaskQueue::TakeTaskQueueImpl() { in TakeTaskQueueImpl()
|
D | work_queue_sets_unittest.cc | 46 TaskQueueImpl::Task FakeTaskWithEnqueueOrder(int enqueue_order) { in FakeTaskWithEnqueueOrder() 47 TaskQueueImpl::Task fake_task( in FakeTaskWithEnqueueOrder() 53 TaskQueueImpl::Task FakeNonNestableTaskWithEnqueueOrder(int enqueue_order) { in FakeNonNestableTaskWithEnqueueOrder() 54 TaskQueueImpl::Task fake_task( in FakeNonNestableTaskWithEnqueueOrder()
|
D | sequence_manager.h | 118 virtual std::unique_ptr<internal::TaskQueueImpl> CreateTaskQueueImpl(
|
D | sequence_manager_impl_unittest.cc | 2230 std::vector<internal::TaskQueueImpl*>* task_sources) { in CurrentlyExecutingTaskQueueTestTask() 2241 std::vector<internal::TaskQueueImpl*> task_sources; in TEST_P() 2256 std::vector<internal::TaskQueueImpl*>* task_sources, in RunloopCurrentlyExecutingTaskQueueTestTask() 2277 std::vector<internal::TaskQueueImpl*> task_sources; in TEST_P() 2904 internal::TaskQueueImpl::OnTaskStartedHandler()); in UnsetOnTaskHandlers() 2906 internal::TaskQueueImpl::OnTaskStartedHandler()); in UnsetOnTaskHandlers()
|
/external/libchrome/base/task/sequence_manager/test/ |
D | test_task_queue.cc | 12 TestTaskQueue::TestTaskQueue(std::unique_ptr<internal::TaskQueueImpl> impl, in TestTaskQueue()
|
D | test_task_queue.h | 16 explicit TestTaskQueue(std::unique_ptr<internal::TaskQueueImpl> impl,
|