TaskScheduler: Remove base/task_scheduler/utils.h/.cc

base/task_scheduler/delayed_task_manager_unittest.cc

 // Copyright 2016 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "base/task_scheduler/delayed_task_manager.h"
 
 #include <memory>
 #include <utility>
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
+#include "base/logging.h"
 #include "base/memory/ref_counted.h"
 #include "base/task_scheduler/scheduler_lock.h"
-#include "base/task_scheduler/scheduler_task_executor.h"
+#include "base/task_scheduler/scheduler_thread_pool.h"
 #include "base/task_scheduler/sequence.h"
 #include "base/task_scheduler/task.h"
 #include "base/time/time.h"
 #include "testing/gmock/include/gmock/gmock.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 namespace base {
 namespace internal {
 namespace {
 
@@ skipping 10 matching lines @@
   TimeTicks Now() const override { return now_; }
 
   MOCK_METHOD0(OnDelayedRunTimeUpdated, void());
 
  private:
   TimeTicks now_ = TimeTicks::Now();
 
   DISALLOW_COPY_AND_ASSIGN(TestDelayedTaskManager);
 };
 
-class MockSchedulerTaskExecutor : public SchedulerTaskExecutor {
+class MockSchedulerThreadPool : public SchedulerThreadPool {
  public:
-  void PostTaskWithSequence(std::unique_ptr<Task> task,
-                            scoped_refptr<Sequence> sequence) override {
-    PostTaskWithSequenceMock(task.get(), sequence.get());
+  // SchedulerThreadPool:
+  scoped_refptr<TaskRunner> CreateTaskRunnerWithTraits(
+      const TaskTraits& traits,
+      ExecutionMode execution_mode) override {
+    NOTREACHED();
+    return nullptr;
   }
 
-  MOCK_METHOD2(PostTaskWithSequenceMock, void(const Task*, const Sequence*));
+  void EnqueueSequence(scoped_refptr<Sequence> sequence,
+                       const SequenceSortKey& sequence_sort_key) override {
+    NOTREACHED();
+  }
+
+  bool PostTaskWithSequence(std::unique_ptr<Task> task,
+                            scoped_refptr<Sequence> sequence) override {
+    NOTREACHED();
+    return true;
+  }
+
+  void PostTaskWithSequenceNow(std::unique_ptr<Task> task,
+                               scoped_refptr<Sequence> sequence) override {
+    PostTaskWithSequenceNowMock(task.get(), sequence.get());
+  }
+
+  MOCK_METHOD2(PostTaskWithSequenceNowMock, void(const Task*, const Sequence*));
 };
 
+}  // namespace
+
 // Verify that GetDelayedRunTime() returns a null TimeTicks when there are
 // no pending delayed tasks.
 TEST(TaskSchedulerDelayedTaskManagerTest,
      GetDelayedRunTimeNoPendingDelayedTasks) {
   TestDelayedTaskManager manager;
   EXPECT_EQ(TimeTicks(), manager.GetDelayedRunTime());
 }
 
 // Verify that a delayed task isn't posted before it is ripe for execution.
 TEST(TaskSchedulerDelayedTaskManagerTest, PostReadyTaskBeforeDelayedRunTime) {
   testing::StrictMock<TestDelayedTaskManager> manager;
 
   std::unique_ptr<Task> task(
       new Task(FROM_HERE, Bind(&DoNothing), TaskTraits(),
                manager.Now() + TimeDelta::FromSeconds(1)));
   const Task* task_raw = task.get();
   scoped_refptr<Sequence> sequence(new Sequence);
-  testing::StrictMock<MockSchedulerTaskExecutor> executor;
+  testing::StrictMock<MockSchedulerThreadPool> thread_pool;
 
   // Add |task| to the DelayedTaskManager.
   EXPECT_CALL(manager, OnDelayedRunTimeUpdated());
-  manager.AddDelayedTask(std::move(task), sequence, &executor);
+  manager.AddDelayedTask(std::move(task), sequence, &thread_pool);
   testing::Mock::VerifyAndClear(&manager);
   EXPECT_EQ(task_raw->delayed_run_time, manager.GetDelayedRunTime());
 
   // Ask the DelayedTaskManager to post tasks that are ripe for execution. Don't
-  // expect any call to the mock method of |executor|.
+  // expect any call to the mock method of |thread_pool|.
   manager.PostReadyTasks();
 
   // The delayed run time shouldn't have changed.
   EXPECT_EQ(task_raw->delayed_run_time, manager.GetDelayedRunTime());
 }
 
 // Verify that a delayed task is posted when PostReadyTasks() is called with the
 // current time equal to the task's delayed run time.
 TEST(TaskSchedulerDelayedTaskManagerTest, PostReadyTasksAtDelayedRunTime) {
   testing::StrictMock<TestDelayedTaskManager> manager;
 
   std::unique_ptr<Task> task(
       new Task(FROM_HERE, Bind(&DoNothing), TaskTraits(),
                manager.Now() + TimeDelta::FromSeconds(1)));
   const Task* task_raw = task.get();
   scoped_refptr<Sequence> sequence(new Sequence);
-  testing::StrictMock<MockSchedulerTaskExecutor> executor;
+  testing::StrictMock<MockSchedulerThreadPool> thread_pool;
 
   // Add |task| to the DelayedTaskManager.
   EXPECT_CALL(manager, OnDelayedRunTimeUpdated());
-  manager.AddDelayedTask(std::move(task), sequence, &executor);
+  manager.AddDelayedTask(std::move(task), sequence, &thread_pool);
   testing::Mock::VerifyAndClear(&manager);
   EXPECT_EQ(task_raw->delayed_run_time, manager.GetDelayedRunTime());
 
   // Fast-forward time to |task_raw|'s delayed run time.
   manager.SetCurrentTime(task_raw->delayed_run_time);
 
   // Ask the DelayedTaskManager to post tasks that are ripe for execution.
-  EXPECT_CALL(executor, PostTaskWithSequenceMock(task_raw, sequence.get()));
+  EXPECT_CALL(thread_pool,
+              PostTaskWithSequenceNowMock(task_raw, sequence.get()));
   manager.PostReadyTasks();
   testing::Mock::VerifyAndClear(&manager);
   EXPECT_EQ(TimeTicks(), manager.GetDelayedRunTime());
 }
 
 // Verify that a delayed task is posted when PostReadyTasks() is called with the
 // current time greater than the task's delayed run time.
 TEST(TaskSchedulerDelayedTaskManagerTest, PostReadyTasksAfterDelayedRunTime) {
   testing::StrictMock<TestDelayedTaskManager> manager;
 
   std::unique_ptr<Task> task(
       new Task(FROM_HERE, Bind(&DoNothing), TaskTraits(),
                manager.Now() + TimeDelta::FromSeconds(1)));
   const Task* task_raw = task.get();
   scoped_refptr<Sequence> sequence(new Sequence);
-  testing::StrictMock<MockSchedulerTaskExecutor> executor;
+  testing::StrictMock<MockSchedulerThreadPool> thread_pool;
 
   // Add |task| to the DelayedTaskManager.
   EXPECT_CALL(manager, OnDelayedRunTimeUpdated());
-  manager.AddDelayedTask(std::move(task), sequence, &executor);
+  manager.AddDelayedTask(std::move(task), sequence, &thread_pool);
   testing::Mock::VerifyAndClear(&manager);
   EXPECT_EQ(task_raw->delayed_run_time, manager.GetDelayedRunTime());
 
   // Fast-forward time to |task_raw|'s delayed run time.
   manager.SetCurrentTime(task_raw->delayed_run_time +
                          TimeDelta::FromSeconds(10));
 
   // Ask the DelayedTaskManager to post tasks that are ripe for execution.
-  EXPECT_CALL(executor, PostTaskWithSequenceMock(task_raw, sequence.get()));
+  EXPECT_CALL(thread_pool,
+              PostTaskWithSequenceNowMock(task_raw, sequence.get()));
   manager.PostReadyTasks();
   testing::Mock::VerifyAndClear(&manager);
   EXPECT_EQ(TimeTicks(), manager.GetDelayedRunTime());
 }
 
 // Verify that when multiple tasks are added to a DelayedTaskManager, they are
 // posted when they become ripe for execution.
 TEST(TaskSchedulerDelayedTaskManagerTest, AddAndPostReadyTasks) {
   testing::StrictMock<TestDelayedTaskManager> manager;
 
   scoped_refptr<Sequence> sequence(new Sequence);
-  testing::StrictMock<MockSchedulerTaskExecutor> executor;
+  testing::StrictMock<MockSchedulerThreadPool> thread_pool;
 
   std::unique_ptr<Task> task_a(
       new Task(FROM_HERE, Bind(&DoNothing), TaskTraits(),
                manager.Now() + TimeDelta::FromSeconds(2)));
   const Task* task_a_raw = task_a.get();
 
   std::unique_ptr<Task> task_b(
       new Task(FROM_HERE, Bind(&DoNothing), TaskTraits(),
                manager.Now() + TimeDelta::FromSeconds(2)));
   const Task* task_b_raw = task_b.get();
 
   std::unique_ptr<Task> task_c(
       new Task(FROM_HERE, Bind(&DoNothing), TaskTraits(),
                manager.Now() + TimeDelta::FromSeconds(1)));
   const Task* task_c_raw = task_c.get();
 
   // Add |task_a| to the DelayedTaskManager. The delayed run time should be
   // updated to |task_a|'s delayed run time.
   EXPECT_CALL(manager, OnDelayedRunTimeUpdated());
-  manager.AddDelayedTask(std::move(task_a), sequence, &executor);
+  manager.AddDelayedTask(std::move(task_a), sequence, &thread_pool);
   testing::Mock::VerifyAndClear(&manager);
   EXPECT_EQ(task_a_raw->delayed_run_time, manager.GetDelayedRunTime());
 
   // Add |task_b| to the DelayedTaskManager. The delayed run time shouldn't
   // change.
-  manager.AddDelayedTask(std::move(task_b), sequence, &executor);
+  manager.AddDelayedTask(std::move(task_b), sequence, &thread_pool);
   testing::Mock::VerifyAndClear(&manager);
   EXPECT_EQ(task_a_raw->delayed_run_time, manager.GetDelayedRunTime());
 
   // Add |task_c| to the DelayedTaskManager. The delayed run time should be
   // updated to |task_c|'s delayed run time.
   EXPECT_CALL(manager, OnDelayedRunTimeUpdated());
-  manager.AddDelayedTask(std::move(task_c), sequence, &executor);
+  manager.AddDelayedTask(std::move(task_c), sequence, &thread_pool);
   testing::Mock::VerifyAndClear(&manager);
   EXPECT_EQ(task_c_raw->delayed_run_time, manager.GetDelayedRunTime());
 
   // Fast-forward time to |task_c_raw|'s delayed run time.
   manager.SetCurrentTime(task_c_raw->delayed_run_time);
 
   // Ask the DelayedTaskManager to post tasks that are ripe for execution.
   // |task_c_raw| should be posted and the delayed run time should become
   // |task_a_raw|'s delayed run time.
-  EXPECT_CALL(executor, PostTaskWithSequenceMock(task_c_raw, sequence.get()));
+  EXPECT_CALL(thread_pool,
+              PostTaskWithSequenceNowMock(task_c_raw, sequence.get()));
   manager.PostReadyTasks();
-  testing::Mock::VerifyAndClear(&executor);
+  testing::Mock::VerifyAndClear(&thread_pool);
   EXPECT_EQ(task_a_raw->delayed_run_time, manager.GetDelayedRunTime());
 
   // Fast-forward time to |task_a_raw|'s delayed run time.
   manager.SetCurrentTime(task_a_raw->delayed_run_time);
 
   // Ask the DelayedTaskManager to post tasks that are ripe for execution.
   // |task_a_raw| and |task_b_raw| should be posted and the delayed run time
   // should become a null TimeTicks.
-  EXPECT_CALL(executor, PostTaskWithSequenceMock(task_a_raw, sequence.get()));
-  EXPECT_CALL(executor, PostTaskWithSequenceMock(task_b_raw, sequence.get()));
+  EXPECT_CALL(thread_pool,
+              PostTaskWithSequenceNowMock(task_a_raw, sequence.get()));
+  EXPECT_CALL(thread_pool,
+              PostTaskWithSequenceNowMock(task_b_raw, sequence.get()));
   manager.PostReadyTasks();
-  testing::Mock::VerifyAndClear(&executor);
+  testing::Mock::VerifyAndClear(&thread_pool);
   EXPECT_EQ(TimeTicks(), manager.GetDelayedRunTime());
 }
 
-}  // namespace
 }  // namespace internal
 }  // namespace base