| /external/libchrome/base/task/ |
| D | cancelable_task_tracker_unittest.cc | 36 CancelableTaskTracker task_tracker_; member in base::__anon533752120111::CancelableTaskTrackerTest
88 ignore_result(task_tracker_.PostTask(worker_thread.task_runner().get(), in TEST_F()
92 ignore_result(task_tracker_.PostTaskAndReply( in TEST_F()
97 ignore_result(task_tracker_.NewTrackedTaskId(&is_canceled)); in TEST_F()
112 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTask( in TEST_F()
118 task_tracker_.TryCancel(task_id); in TEST_F()
131 task_tracker_.PostTaskAndReply(test_task_runner.get(), in TEST_F()
137 task_tracker_.TryCancel(task_id); in TEST_F()
150 task_tracker_.PostTaskAndReply(test_task_runner.get(), in TEST_F()
158 task_tracker_.TryCancel(task_id); in TEST_F()
[all …]
|
| /external/libchrome/base/test/ |
| D | sequenced_task_runner_test_template.h | 119 : task_tracker_(new internal::SequencedTaskTracker()) {} in SequencedTaskRunnerTest()
121 const scoped_refptr<internal::SequencedTaskTracker> task_tracker_; variable
138 this->task_tracker_->PostWrappedNonNestableTask( in TYPED_TEST_P()
142 this->task_tracker_->PostWrappedNonNestableTask(task_runner.get(), in TYPED_TEST_P()
148 EXPECT_TRUE(CheckNonNestableInvariants(this->task_tracker_->GetTaskEvents(), in TYPED_TEST_P()
162 this->task_tracker_->PostWrappedNestableTask( in TYPED_TEST_P()
166 this->task_tracker_->PostWrappedNestableTask(task_runner.get(), Closure()); in TYPED_TEST_P()
171 EXPECT_TRUE(CheckNonNestableInvariants(this->task_tracker_->GetTaskEvents(), in TYPED_TEST_P()
187 this->task_tracker_->PostWrappedDelayedNonNestableTask( in TYPED_TEST_P()
192 this->task_tracker_->WaitForCompletedTasks(kTaskCount); in TYPED_TEST_P()
[all …]
|
| D | task_runner_test_template.h | 112 TaskRunnerTest() : task_tracker_(new test::TaskTracker()) {} in TaskRunnerTest()
114 const scoped_refptr<test::TaskTracker> task_tracker_; variable
132 const Closure& ith_task = this->task_tracker_->WrapTask(Closure(), i); in TYPED_TEST_P()
141 this->task_tracker_->GetTaskRunCounts()); in TYPED_TEST_P()
154 const Closure& ith_task = this->task_tracker_->WrapTask(Closure(), i); in TYPED_TEST_P()
162 this->task_tracker_->WaitForCompletedTasks(expected_total_tasks); in TYPED_TEST_P()
166 this->task_tracker_->GetTaskRunCounts()); in TYPED_TEST_P()
202 const Closure& ith_task_runner_task = this->task_tracker_->WrapTask( in TYPED_TEST_P()
206 const Closure& ith_non_task_runner_task = this->task_tracker_->WrapTask( in TYPED_TEST_P()
221 this->task_tracker_->GetTaskRunCounts()); in TYPED_TEST_P()
|
| D | scoped_task_environment.cc | 121 task_tracker_(new TestTaskTracker()) { in ScopedTaskEnvironment()
137 "ScopedTaskEnvironment", WrapUnique(task_tracker_))); in ScopedTaskEnvironment()
143 CHECK(task_tracker_->DisallowRunTasks()); in ScopedTaskEnvironment()
154 task_tracker_->AllowRunTasks(); in ~ScopedTaskEnvironment()
210 task_tracker_->AllowRunTasks(); in RunUntilIdle()
223 if (!task_tracker_->DisallowRunTasks()) in RunUntilIdle()
250 if (!task_tracker_->HasIncompleteUndelayedTasksForTesting()) in RunUntilIdle()
257 task_tracker_->AllowRunTasks(); in RunUntilIdle()
|
| D | scoped_task_environment.h | 165 TestTaskTracker* const task_tracker_; variable
|
| /external/libchrome/base/task_scheduler/ |
| D | task_scheduler_impl.cc | 36 : task_tracker_(std::move(task_tracker)), in TaskSchedulerImpl()
37 service_thread_(std::make_unique<ServiceThread>(task_tracker_.get())), in TaskSchedulerImpl()
38 single_thread_task_runner_manager_(task_tracker_->GetTrackedRef(), in TaskSchedulerImpl()
60 task_tracker_->GetTrackedRef(), &delayed_task_manager_)); in TaskSchedulerImpl()
113 task_tracker_->set_watch_file_descriptor_message_loop( in Start()
117 task_tracker_->set_service_thread_handle(service_thread_->GetThreadHandle()); in Start()
240 task_tracker_->Shutdown(); in Shutdown()
244 task_tracker_->FlushForTesting(); in FlushForTesting()
248 task_tracker_->FlushAsyncForTesting(std::move(flush_callback)); in FlushAsyncForTesting()
|
| D | scheduler_worker_pool_unittest.cc | 117 task_tracker_.GetTrackedRef(), &delayed_task_manager_); in CreateWorkerPool()
122 task_tracker_.GetTrackedRef(), &delayed_task_manager_); in CreateWorkerPool()
153 TaskTracker task_tracker_ = {"Test"}; member in base::internal::__anonaa84deaa0111::TaskSchedulerWorkerPoolTest
186 task_tracker_.FlushForTesting(); in TEST_P()
208 task_tracker_.FlushForTesting(); in TEST_P()
216 task_tracker_.Shutdown(); in TEST_P()
227 task_tracker_.Shutdown(); in TEST_P()
317 task_tracker_.FlushForTesting(); in TEST_P()
|
| D | scheduler_single_thread_task_runner_manager_unittest.cc | 49 task_tracker_.GetTrackedRef(), &delayed_task_manager_); in SetUp()
70 TaskTracker task_tracker_ = {"Test"}; member in base::internal::__anond54e0ab50111::TaskSchedulerSingleThreadTaskRunnerManagerTest
118 task_tracker_.Shutdown(); in TEST_F()
144 task_tracker_.Shutdown(); in TEST_F()
187 task_tracker_.Shutdown(); in TEST_F()
232 task_tracker_.Shutdown(); in TEST_F()
319 task_tracker_.Shutdown(); in TEST_P()
345 task_tracker_.Shutdown(); in TEST_P()
390 task_tracker_.Shutdown(); in TEST_P()
511 task_tracker_.Shutdown(); in TEST_P()
[all …]
|
| D | service_thread.cc | 28 : Thread("TaskSchedulerServiceThread"), task_tracker_(task_tracker) {} in ServiceThread()
39 if (task_tracker_ && TaskScheduler::GetInstance()) { in Init()
87 BindOnce(&TaskTracker::RecordLatencyHistogram, Unretained(task_tracker_), in PerformHeartbeatLatencyReport()
|
| D | scheduler_single_thread_task_runner_manager.cc | 183 task_tracker_(std::move(task_tracker)) {} in SchedulerWorkerCOMDelegate()
252 if (task_tracker_->WillPostTask(&pump_message_task)) { in GetWorkFromWindowsMessageQueue()
265 const TrackedRef<TaskTracker> task_tracker_; member in base::internal::__anon836862560111::SchedulerWorkerCOMDelegate
303 if (!outer_->task_tracker_->WillPostTask(&task)) in PostDelayedTask()
365 sequence = outer_->task_tracker_->WillScheduleSequence( in PostTaskNow()
389 : task_tracker_(std::move(task_tracker)), in SchedulerSingleThreadTaskRunnerManager()
391 DCHECK(task_tracker_); in SchedulerSingleThreadTaskRunnerManager()
559 task_tracker_); in CreateSchedulerWorkerDelegate()
575 priority_hint, std::move(delegate), task_tracker_); in CreateAndRegisterSchedulerWorker()
|
| D | scheduler_worker_pool.cc | 148 if (!task_tracker_->WillPostTask(&task)) in PostTaskWithSequence()
173 : task_tracker_(std::move(task_tracker)), in SchedulerWorkerPool()
175 DCHECK(task_tracker_); in SchedulerWorkerPool()
212 sequence = task_tracker_->WillScheduleSequence(std::move(sequence), this); in PostTaskWithSequenceNow()
|
| D | scheduler_worker.cc | 49 task_tracker_(std::move(task_tracker)), in SchedulerWorker()
58 DCHECK(task_tracker_); in SchedulerWorker()
158 task_tracker_->IsShutdownComplete(); in ShouldExit()
163 if (task_tracker_->HasShutdownStarted()) in GetDesiredThreadPriority()
330 task_tracker_->RunAndPopNextTask(std::move(sequence), delegate_.get()); in RunWorker()
|
| D | scheduler_worker_unittest.cc | 88 task_tracker_.GetTrackedRef()); in SetUp()
189 EXPECT_TRUE(outer_->task_tracker_.WillPostTask(&task)); in GetWork()
201 sequence = outer_->task_tracker_.WillScheduleSequence(std::move(sequence), in GetWork()
264 TaskTracker task_tracker_ = {"Test"}; member in base::internal::__anonce7fc1310111::TaskSchedulerWorkerTest
424 : task_tracker_(task_tracker), controls_(new Controls()) {} in ControllableCleanupDelegate()
456 EXPECT_TRUE(task_tracker_->WillPostTask(&task)); in GetWork()
459 task_tracker_->WillScheduleSequence(std::move(sequence), nullptr); in GetWork()
488 TaskTracker* const task_tracker_; member in base::internal::__anonce7fc1310211::ControllableCleanupDelegate
|
| D | scheduler_worker_stack_unittest.cc | 51 task_tracker_.GetTrackedRef()); in SetUp()
55 task_tracker_.GetTrackedRef()); in SetUp()
59 task_tracker_.GetTrackedRef()); in SetUp()
64 TaskTracker task_tracker_ = {"Test"}; member in base::internal::__anon8b922aa60111::TaskSchedulerWorkerStackTest
|
| D | scheduler_worker_pool_impl_unittest.cc | 88 task_tracker_.FlushForTesting(); in CommonTearDown()
99 task_tracker_.GetTrackedRef(), &delayed_task_manager_); in CreateWorkerPool()
119 TaskTracker task_tracker_ = {"Test"}; member in base::internal::__anon30c1a4bb0111::TaskSchedulerWorkerPoolImplTestBase
430 task_tracker_.FlushForTesting(); in TEST_F()
924 task_tracker_.FlushForTesting(); in TEST_F()
1088 task_tracker_.FlushForTesting(); in TEST_P()
1153 task_tracker_.FlushForTesting(); in TEST_P()
1225 task_tracker_.FlushForTesting(); in TEST_P()
1262 task_tracker_.FlushForTesting(); in TEST_F()
1314 task_tracker_.FlushForTesting(); in TEST_F()
[all …]
|
| D | service_thread.h | 47 const TaskTracker* const task_tracker_; variable
|
| D | scheduler_worker_pool.h | 69 const TrackedRef<TaskTracker> task_tracker_; variable
|
| D | scheduler_single_thread_task_runner_manager.h | 121 const TrackedRef<TaskTracker> task_tracker_; variable
|
| D | task_scheduler_impl.h | 100 const std::unique_ptr<TaskTrackerImpl> task_tracker_; variable
|
| D | scheduler_worker.h | 235 const TrackedRef<TaskTracker> task_tracker_; variable
|
| D | scheduler_worker_pool_impl.cc | 624 bool shutdown_complete = outer_->task_tracker_->IsShutdownComplete(); in OnMainExit()
877 task_tracker_, &lock_, backward_compatibility_); in CreateRegisterAndStartSchedulerWorkerLockRequired()
|