| Index: base/task_scheduler/scheduler_worker_pool_impl.cc
|
| diff --git a/base/task_scheduler/scheduler_worker_pool_impl.cc b/base/task_scheduler/scheduler_worker_pool_impl.cc
|
| index 155f42dc132051ef24e91d27d8a4e512450a664d..f15cc937c7122d62b05335de9644c38ee907be50 100644
|
| --- a/base/task_scheduler/scheduler_worker_pool_impl.cc
|
| +++ b/base/task_scheduler/scheduler_worker_pool_impl.cc
|
| @@ -320,26 +320,6 @@ std::unique_ptr<SchedulerWorkerPoolImpl> SchedulerWorkerPoolImpl::Create(
|
| return nullptr;
|
| }
|
|
|
| -void SchedulerWorkerPoolImpl::WaitForAllWorkersIdleForTesting() {
|
| - AutoSchedulerLock auto_lock(idle_workers_stack_lock_);
|
| - while (idle_workers_stack_.Size() < workers_.size())
|
| - idle_workers_stack_cv_for_testing_->Wait();
|
| -}
|
| -
|
| -void SchedulerWorkerPoolImpl::JoinForTesting() {
|
| - DCHECK(!CanWorkerDetachForTesting() || suggested_reclaim_time_.is_max()) <<
|
| - "Workers can detach during join.";
|
| - for (const auto& worker : workers_)
|
| - worker->JoinForTesting();
|
| -
|
| - DCHECK(!join_for_testing_returned_.IsSignaled());
|
| - join_for_testing_returned_.Signal();
|
| -}
|
| -
|
| -void SchedulerWorkerPoolImpl::DisallowWorkerDetachmentForTesting() {
|
| - worker_detachment_disallowed_.Set();
|
| -}
|
| -
|
| scoped_refptr<TaskRunner> SchedulerWorkerPoolImpl::CreateTaskRunnerWithTraits(
|
| const TaskTraits& traits) {
|
| return make_scoped_refptr(new SchedulerParallelTaskRunner(traits, this));
|
| @@ -452,6 +432,26 @@ void SchedulerWorkerPoolImpl::GetHistograms(
|
| histograms->push_back(num_tasks_between_waits_histogram_);
|
| }
|
|
|
| +void SchedulerWorkerPoolImpl::WaitForAllWorkersIdleForTesting() {
|
| + AutoSchedulerLock auto_lock(idle_workers_stack_lock_);
|
| + while (idle_workers_stack_.Size() < workers_.size())
|
| + idle_workers_stack_cv_for_testing_->Wait();
|
| +}
|
| +
|
| +void SchedulerWorkerPoolImpl::JoinForTesting() {
|
| + DCHECK(!CanWorkerDetachForTesting() || suggested_reclaim_time_.is_max())
|
| + << "Workers can detach during join.";
|
| + for (const auto& worker : workers_)
|
| + worker->JoinForTesting();
|
| +
|
| + DCHECK(!join_for_testing_returned_.IsSignaled());
|
| + join_for_testing_returned_.Signal();
|
| +}
|
| +
|
| +void SchedulerWorkerPoolImpl::DisallowWorkerDetachmentForTesting() {
|
| + worker_detachment_disallowed_.Set();
|
| +}
|
| +
|
| SchedulerWorkerPoolImpl::SchedulerSingleThreadTaskRunner::
|
| SchedulerSingleThreadTaskRunner(const TaskTraits& traits,
|
| SchedulerWorkerPool* worker_pool,
|
|
|