Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(2068)

Unified Diff: content/renderer/scheduler/task_queue_manager_unittest.cc

Issue 968073003: [content]: Add support for long idle times in the Blink Scheduler. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@long_idle_4
Patch Set: Enable for testing Created 5 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « content/renderer/scheduler/task_queue_manager.cc ('k') | no next file » | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: content/renderer/scheduler/task_queue_manager_unittest.cc
diff --git a/content/renderer/scheduler/task_queue_manager_unittest.cc b/content/renderer/scheduler/task_queue_manager_unittest.cc
index 845e9bad2c4e7e1bdb27d819b1c20774483338db..926f30d69752e190889bc1cb0dc66812d8be48c1 100644
--- a/content/renderer/scheduler/task_queue_manager_unittest.cc
+++ b/content/renderer/scheduler/task_queue_manager_unittest.cc
@@ -840,6 +840,54 @@ TEST_F(TaskQueueManagerTest, ThreadCheckAfterTermination) {
EXPECT_TRUE(runner->RunsTasksOnCurrentThread());
}
+TEST_F(TaskQueueManagerTest, NextPendingDelayedTaskRunTime) {
+ scoped_refptr<cc::TestNowSource> clock(cc::TestNowSource::Create());
+ Initialize(2u);
+ manager_->SetTimeSourceForTesting(clock);
+
+ scoped_refptr<base::SingleThreadTaskRunner> runners[2] = {
+ manager_->TaskRunnerForQueue(0), manager_->TaskRunnerForQueue(1)};
+
+ // With no delayed tasks.
+ EXPECT_TRUE(manager_->NextPendingDelayedTaskRunTime().is_null());
+
+ // With a non-delayed task.
+ runners[0]->PostTask(FROM_HERE, base::Bind(&NullTestTask));
+ EXPECT_TRUE(manager_->NextPendingDelayedTaskRunTime().is_null());
+
+ // With a delayed task.
+ base::TimeDelta expected_delay = base::TimeDelta::FromMilliseconds(50);
+ runners[0]->PostDelayedTask(
+ FROM_HERE, base::Bind(&NullTestTask), expected_delay);
+ EXPECT_EQ(clock->Now() + expected_delay,
+ manager_->NextPendingDelayedTaskRunTime());
+
+ // With another delayed task in the same queue with a longer delay.
+ runners[0]->PostDelayedTask(
+ FROM_HERE, base::Bind(&NullTestTask),
+ base::TimeDelta::FromMilliseconds(100));
+ EXPECT_EQ(clock->Now() + expected_delay,
+ manager_->NextPendingDelayedTaskRunTime());
+
+ // With another delayed task in the same queue with a shorter delay.
+ expected_delay = base::TimeDelta::FromMilliseconds(20);
+ runners[0]->PostDelayedTask(
+ FROM_HERE, base::Bind(&NullTestTask), expected_delay);
+ EXPECT_EQ(clock->Now() + expected_delay,
+ manager_->NextPendingDelayedTaskRunTime());
+
+ // With another delayed task in a different queue with a shorter delay.
+ expected_delay = base::TimeDelta::FromMilliseconds(10);
+ runners[1]->PostDelayedTask(
+ FROM_HERE, base::Bind(&NullTestTask), expected_delay);
+ EXPECT_EQ(clock->Now() + expected_delay,
+ manager_->NextPendingDelayedTaskRunTime());
+
+ // Test it updates as time progresses
+ clock->AdvanceNow(expected_delay);
+ EXPECT_EQ(clock->Now(), manager_->NextPendingDelayedTaskRunTime());
+}
+
} // namespace
} // namespace content
« no previous file with comments | « content/renderer/scheduler/task_queue_manager.cc ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698