Index: base/task_scheduler/scheduler_worker_pool_impl_unittest.cc |
diff --git a/base/task_scheduler/scheduler_worker_pool_impl_unittest.cc b/base/task_scheduler/scheduler_worker_pool_impl_unittest.cc |
index 86f63272011d9b8b3846330c86d04c8bb6abf59a..5bb4a816df508fe8dae98d8d90f4a346365fbdb3 100644 |
--- a/base/task_scheduler/scheduler_worker_pool_impl_unittest.cc |
+++ b/base/task_scheduler/scheduler_worker_pool_impl_unittest.cc |
@@ -78,15 +78,13 @@ class TaskSchedulerWorkerPoolImplTest |
void CreateWorkerPool() { |
ASSERT_FALSE(worker_pool_); |
- ASSERT_FALSE(delayed_task_manager_); |
service_thread_.Start(); |
- delayed_task_manager_ = |
- base::MakeUnique<DelayedTaskManager>(service_thread_.task_runner()); |
+ delayed_task_manager_.Start(service_thread_.task_runner()); |
worker_pool_ = MakeUnique<SchedulerWorkerPoolImpl>( |
"TestWorkerPool", ThreadPriority::NORMAL, |
Bind(&TaskSchedulerWorkerPoolImplTest::ReEnqueueSequenceCallback, |
Unretained(this)), |
- &task_tracker_, delayed_task_manager_.get()); |
+ &task_tracker_, &delayed_task_manager_); |
ASSERT_TRUE(worker_pool_); |
} |
@@ -107,7 +105,6 @@ class TaskSchedulerWorkerPoolImplTest |
TaskTracker task_tracker_; |
Thread service_thread_; |
- std::unique_ptr<DelayedTaskManager> delayed_task_manager_; |
private: |
void ReEnqueueSequenceCallback(scoped_refptr<Sequence> sequence) { |
@@ -118,6 +115,8 @@ class TaskSchedulerWorkerPoolImplTest |
worker_pool_->ReEnqueueSequence(std::move(sequence), sort_key); |
} |
+ DelayedTaskManager delayed_task_manager_; |
+ |
DISALLOW_COPY_AND_ASSIGN(TaskSchedulerWorkerPoolImplTest); |
}; |
@@ -792,8 +791,8 @@ void NotReachedReEnqueueSequenceCallback(scoped_refptr<Sequence> sequence) { |
TEST(TaskSchedulerWorkerPoolStandbyPolicyTest, InitLazy) { |
TaskTracker task_tracker; |
- DelayedTaskManager delayed_task_manager( |
- make_scoped_refptr(new TestSimpleTaskRunner)); |
+ DelayedTaskManager delayed_task_manager; |
+ delayed_task_manager.Start(make_scoped_refptr(new TestSimpleTaskRunner)); |
auto worker_pool = MakeUnique<SchedulerWorkerPoolImpl>( |
"LazyPolicyWorkerPool", ThreadPriority::NORMAL, |
Bind(&NotReachedReEnqueueSequenceCallback), &task_tracker, |
@@ -807,8 +806,8 @@ TEST(TaskSchedulerWorkerPoolStandbyPolicyTest, InitLazy) { |
TEST(TaskSchedulerWorkerPoolStandbyPolicyTest, InitOne) { |
TaskTracker task_tracker; |
- DelayedTaskManager delayed_task_manager( |
- make_scoped_refptr(new TestSimpleTaskRunner)); |
+ DelayedTaskManager delayed_task_manager; |
+ delayed_task_manager.Start(make_scoped_refptr(new TestSimpleTaskRunner)); |
auto worker_pool = MakeUnique<SchedulerWorkerPoolImpl>( |
"OnePolicyWorkerPool", ThreadPriority::NORMAL, |
Bind(&NotReachedReEnqueueSequenceCallback), &task_tracker, |