TaskScheduler [9] Delayed Task Manager

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/task_scheduler/scheduler_lock.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 {
+
+class TestDelayedTaskManager : public DelayedTaskManager {
+ public:
+  TestDelayedTaskManager()
+      : DelayedTaskManager(
+            Bind(&TestDelayedTaskManager::OnDelayedTaskReadyTimeChanged,
+                 Unretained(this))) {}
+
+  void SetTime(TimeTicks now) { now_ = now; }

[robliao, 2016/04/01 20:48:25]

Maybe SetCurrentTime?

[fdoray, 2016/04/01 21:21:58]

Done.

+  TimeTicks Now() override { return now_; }
+
+  MOCK_METHOD0(OnDelayedTaskReadyTimeChanged, void());
+
+  DelayedTaskManager::PostTaskCallback GetPostTaskCallback() {
+    return Bind(&TestDelayedTaskManager::PostTaskCallback, Unretained(this));
+  }
+
+  void PostTaskCallback(std::unique_ptr<Task> task) {
+    PostTaskCallbackMock(task.get());
+
+    // Acquire a SchedulerLock with no predecessor to verify that no lock
+    // dependency is imposed on this callback.
+    SchedulerLock lock;
+    AutoSchedulerLock auto_lock(lock);
+  }
+  MOCK_METHOD1(PostTaskCallbackMock, void(const Task*));
+
+ private:
+  TimeTicks now_;
+};
+
+// Verify that GetNextDelayedRunTime() returns a null TimeTicks when there are
+// no pending delayed tasks.
+TEST(TaskSchedulerDelayedTaskManagerTest,
+     GetNextDelayedRunTimeNoPendingDelayedTasks) {
+  TestDelayedTaskManager manager;
+  EXPECT_EQ(TimeTicks(), manager.GetNextDelayedRunTime());
+}
+
+// Verify that a delayed task's callback is invoked when PostReadyTasks() is
+// called with the current time equal to the task's delayed run time.
+TEST(TaskSchedulerDelayedTaskManagerTest, AddAndPostTask) {
+  testing::StrictMock<TestDelayedTaskManager> manager;
+
+  std::unique_ptr<Task> task(
+      new Task(FROM_HERE, Bind(&DoNothing), TaskTraits()));
+  task->delayed_run_time = TimeTicks() + TimeDelta::FromSeconds(1);
+  const Task* task_raw = task.get();
+
+  EXPECT_CALL(manager, OnDelayedTaskReadyTimeChanged());
+  manager.AddDelayedTask(std::move(task), manager.GetPostTaskCallback());
+  testing::Mock::VerifyAndClear(&manager);
+  EXPECT_EQ(task_raw->delayed_run_time, manager.GetNextDelayedRunTime());
+
+  manager.SetTime(task_raw->delayed_run_time);
+
+  EXPECT_CALL(manager, PostTaskCallbackMock(task_raw));
+  manager.PostReadyTasks();
+  testing::Mock::VerifyAndClear(&manager);
+  EXPECT_EQ(TimeTicks(), manager.GetNextDelayedRunTime());
+}
+
+// Verify that a delayed task's callback is invoked when PostReadyTasks() is
+// called with the current time greater than the task's delayed run time.
+TEST(TaskSchedulerDelayedTaskManagerTest, AddAndPostTaskLate) {
+  testing::StrictMock<TestDelayedTaskManager> manager;
+
+  std::unique_ptr<Task> task(
+      new Task(FROM_HERE, Bind(&DoNothing), TaskTraits()));
+  task->delayed_run_time = TimeTicks() + TimeDelta::FromSeconds(1);
+  const Task* task_raw = task.get();
+
+  EXPECT_CALL(manager, OnDelayedTaskReadyTimeChanged());
+  manager.AddDelayedTask(std::move(task), manager.GetPostTaskCallback());
+  testing::Mock::VerifyAndClear(&manager);
+  EXPECT_EQ(task_raw->delayed_run_time, manager.GetNextDelayedRunTime());
+
+  manager.SetTime(task_raw->delayed_run_time + TimeDelta::FromSeconds(10));
+
+  EXPECT_CALL(manager, PostTaskCallbackMock(task_raw));
+  manager.PostReadyTasks();
+  testing::Mock::VerifyAndClear(&manager);
+  EXPECT_EQ(TimeTicks(), manager.GetNextDelayedRunTime());
+}
+
+// Verify that when multiple tasks are added to a DelayedTaskManager, their
+// respective callback is invoked when they become ripe for execution.
+TEST(TaskSchedulerDelayedTaskManagerTest, AddAndPostTasks) {
+  testing::StrictMock<TestDelayedTaskManager> manager;
+
+  std::unique_ptr<Task> task_a(
+      new Task(FROM_HERE, Bind(&DoNothing), TaskTraits()));
+  task_a->delayed_run_time = TimeTicks() + TimeDelta::FromSeconds(2);
+  const Task* task_a_raw = task_a.get();
+
+  std::unique_ptr<Task> task_b(
+      new Task(FROM_HERE, Bind(&DoNothing), TaskTraits()));
+  task_b->delayed_run_time = TimeTicks() + TimeDelta::FromSeconds(2);
+  const Task* task_b_raw = task_b.get();
+
+  std::unique_ptr<Task> task_c(
+      new Task(FROM_HERE, Bind(&DoNothing), TaskTraits()));
+  task_c->delayed_run_time = TimeTicks() + TimeDelta::FromSeconds(1);
+  const Task* task_c_raw = task_c.get();
+
+  EXPECT_CALL(manager, OnDelayedTaskReadyTimeChanged());
+  manager.AddDelayedTask(std::move(task_a), manager.GetPostTaskCallback());
+  testing::Mock::VerifyAndClear(&manager);
+  EXPECT_EQ(task_a_raw->delayed_run_time, manager.GetNextDelayedRunTime());
+
+  manager.AddDelayedTask(std::move(task_b), manager.GetPostTaskCallback());
+  testing::Mock::VerifyAndClear(&manager);
+  EXPECT_EQ(task_a_raw->delayed_run_time, manager.GetNextDelayedRunTime());
+
+  EXPECT_CALL(manager, OnDelayedTaskReadyTimeChanged());
+  manager.AddDelayedTask(std::move(task_c), manager.GetPostTaskCallback());
+  testing::Mock::VerifyAndClear(&manager);
+  EXPECT_EQ(task_c_raw->delayed_run_time, manager.GetNextDelayedRunTime());
+
+  manager.SetTime(task_c_raw->delayed_run_time);
+
+  EXPECT_CALL(manager, PostTaskCallbackMock(task_c_raw));
+  manager.PostReadyTasks();
+  testing::Mock::VerifyAndClear(&manager);
+  EXPECT_EQ(task_a_raw->delayed_run_time, manager.GetNextDelayedRunTime());
+
+  manager.SetTime(task_a_raw->delayed_run_time);
+
+  EXPECT_CALL(manager, PostTaskCallbackMock(task_a_raw));
+  EXPECT_CALL(manager, PostTaskCallbackMock(task_b_raw));
+  manager.PostReadyTasks();
+  testing::Mock::VerifyAndClear(&manager);
+  EXPECT_EQ(TimeTicks(), manager.GetNextDelayedRunTime());
+}
+
+}  // namespace
+}  // namespace internal
+}  // namespace base