Home
last modified time | relevance | path

Searched refs:TaskQueueImpl (Results 1 – 22 of 22) sorted by relevance

/external/libchrome/base/task/sequence_manager/
Dtask_queue_impl.cc43 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 …]
Dsequence_manager_impl.h57 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 …]
Dwork_queue.h33 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.
Dtask_queue_selector.h30 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;
Dtime_domain_unittest.cc23 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 …]
Dtime_domain.h25 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;
Dtask_queue_impl.h42 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 …]
Dwork_queue.cc13 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()
Dsequence_manager_impl.cc51 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 …]
Dgraceful_queue_shutdown_helper.h19 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_;
Dtask_queue_selector_unittest.cc36 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 …]
Dtask_queue_selector.cc59 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()
Dtask_queue.h30 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_;
Dgraceful_queue_shutdown_helper.cc19 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()
Dtime_domain.cc44 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()
Dwork_queue_unittest.cc38 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_;
Dtask_queue.cc15 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()
Dwork_queue_sets_unittest.cc46 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()
Dsequence_manager.h118 virtual std::unique_ptr<internal::TaskQueueImpl> CreateTaskQueueImpl(
Dsequence_manager_impl_unittest.cc2230 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/
Dtest_task_queue.cc12 TestTaskQueue::TestTaskQueue(std::unique_ptr<internal::TaskQueueImpl> impl, in TestTaskQueue()
Dtest_task_queue.h16 explicit TestTaskQueue(std::unique_ptr<internal::TaskQueueImpl> impl,