Chromium Code Reviews| Index: components/scheduler/child/worker_scheduler_impl_unittest.cc |
| diff --git a/components/scheduler/child/worker_scheduler_impl_unittest.cc b/components/scheduler/child/worker_scheduler_impl_unittest.cc |
| index c9f34dbcb4fc10b5ea14e16df98ba82f4a8d039f..47b2f0a165371c9ecabb5ab523d7feb783d810b0 100644 |
| --- a/components/scheduler/child/worker_scheduler_impl_unittest.cc |
| +++ b/components/scheduler/child/worker_scheduler_impl_unittest.cc |
| @@ -6,8 +6,8 @@ |
| #include "base/callback.h" |
| #include "base/strings/stringprintf.h" |
| +#include "base/test/simple_test_tick_clock.h" |
| #include "cc/test/ordered_simple_task_runner.h" |
| -#include "cc/test/test_now_source.h" |
| #include "components/scheduler/child/nestable_task_runner_for_test.h" |
| #include "components/scheduler/child/scheduler_message_loop_delegate.h" |
| #include "components/scheduler/child/test_time_source.h" |
| @@ -26,17 +26,18 @@ int TimeTicksToIntMs(const base::TimeTicks& time) { |
| return static_cast<int>((time - base::TimeTicks()).InMilliseconds()); |
| } |
| -void WakeUpTask(std::vector<std::string>* timeline, cc::TestNowSource* clock) { |
| +void WakeUpTask(std::vector<std::string>* timeline, |
| + base::SimpleTestTickClock* clock) { |
| if (timeline) { |
| - timeline->push_back(base::StringPrintf("run WakeUpTask @ %d", |
| - TimeTicksToIntMs(clock->Now()))); |
| + timeline->push_back(base::StringPrintf( |
| + "run WakeUpTask @ %d", TimeTicksToIntMs(clock->NowTicks()))); |
| } |
| } |
| void RecordTimelineTask(std::vector<std::string>* timeline, |
| - cc::TestNowSource* clock) { |
| + base::SimpleTestTickClock* clock) { |
| timeline->push_back(base::StringPrintf("run RecordTimelineTask @ %d", |
| - TimeTicksToIntMs(clock->Now()))); |
| + TimeTicksToIntMs(clock->NowTicks()))); |
| } |
| void AppendToVectorTestTask(std::vector<std::string>* vector, |
| @@ -62,7 +63,7 @@ class WorkerSchedulerImplForTest : public WorkerSchedulerImpl { |
| public: |
| WorkerSchedulerImplForTest( |
| scoped_refptr<NestableSingleThreadTaskRunner> main_task_runner, |
| - scoped_refptr<cc::TestNowSource> clock_) |
| + base::SimpleTestTickClock* clock_) |
| : WorkerSchedulerImpl(main_task_runner), |
| clock_(clock_), |
| timeline_(nullptr) {} |
| @@ -85,26 +86,26 @@ class WorkerSchedulerImplForTest : public WorkerSchedulerImpl { |
| void IsNotQuiescent() override { |
| if (timeline_) { |
| - timeline_->push_back(base::StringPrintf("IsNotQuiescent @ %d", |
| - TimeTicksToIntMs(clock_->Now()))); |
| + timeline_->push_back(base::StringPrintf( |
| + "IsNotQuiescent @ %d", TimeTicksToIntMs(clock_->NowTicks()))); |
| } |
| WorkerSchedulerImpl::IsNotQuiescent(); |
| } |
| - scoped_refptr<cc::TestNowSource> clock_; |
| + base::SimpleTestTickClock* clock_; |
| std::vector<std::string>* timeline_; // NOT OWNED |
| }; |
| class WorkerSchedulerImplTest : public testing::Test { |
| public: |
| WorkerSchedulerImplTest() |
| - : clock_(cc::TestNowSource::Create(5000)), |
| - mock_task_runner_(new cc::OrderedSimpleTaskRunner(clock_, true)), |
| - nestable_task_runner_( |
| - NestableTaskRunnerForTest::Create(mock_task_runner_)), |
| - scheduler_( |
| - new WorkerSchedulerImplForTest(nestable_task_runner_, clock_)), |
| - timeline_(nullptr) { |
| + : clock_(new base::SimpleTestTickClock()), timeline_(nullptr) { |
| + clock_->Advance(base::TimeDelta::FromInternalValue(5000)); |
|
Sami
2015/05/29 14:00:58
Ditto about the starting time value.
Ankur Verma
2015/06/03 14:56:10
Have'nt changed starting values yet as per mithro'
|
| + mock_task_runner_ = new cc::OrderedSimpleTaskRunner(clock_, true); |
| + nestable_task_runner_ = |
| + NestableTaskRunnerForTest::Create(mock_task_runner_); |
| + scheduler_ = make_scoped_ptr( |
| + new WorkerSchedulerImplForTest(nestable_task_runner_, clock_)); |
| scheduler_->GetSchedulerHelperForTesting()->SetTimeSourceForTesting( |
| make_scoped_ptr(new TestTimeSource(clock_))); |
| scheduler_->GetSchedulerHelperForTesting() |
| @@ -134,13 +135,13 @@ class WorkerSchedulerImplTest : public testing::Test { |
| void RunUntilIdle() { |
| if (timeline_) { |
| - timeline_->push_back(base::StringPrintf("RunUntilIdle begin @ %d", |
| - TimeTicksToIntMs(clock_->Now()))); |
| + timeline_->push_back(base::StringPrintf( |
| + "RunUntilIdle begin @ %d", TimeTicksToIntMs(clock_->NowTicks()))); |
| } |
| mock_task_runner_->RunUntilIdle(); |
| if (timeline_) { |
| - timeline_->push_back(base::StringPrintf("RunUntilIdle end @ %d", |
| - TimeTicksToIntMs(clock_->Now()))); |
| + timeline_->push_back(base::StringPrintf( |
| + "RunUntilIdle end @ %d", TimeTicksToIntMs(clock_->NowTicks()))); |
| } |
| } |
| @@ -151,7 +152,7 @@ class WorkerSchedulerImplTest : public testing::Test { |
| // AFTER the delay for this has expired. |
| default_task_runner_->PostDelayedTask( |
| FROM_HERE, base::Bind(&WakeUpTask, base::Unretained(timeline_), |
| - base::Unretained(clock_.get())), |
| + base::Unretained(clock_)), |
| base::TimeDelta::FromMilliseconds(100)); |
| } |
| @@ -188,7 +189,7 @@ class WorkerSchedulerImplTest : public testing::Test { |
| } |
| protected: |
| - scoped_refptr<cc::TestNowSource> clock_; |
| + base::SimpleTestTickClock* clock_; |
|
Sami
2015/05/29 14:00:58
Ditto about scoped_ptr.
Ankur Verma
2015/06/03 14:56:10
Done.
|
| // Only one of mock_task_runner_ or message_loop_ will be set. |
| scoped_refptr<cc::OrderedSimpleTaskRunner> mock_task_runner_; |
| @@ -284,7 +285,7 @@ TEST_F(WorkerSchedulerImplTest, TestIdleDeadlineWithPendingDelayedTask) { |
| // Post a delayed task timed to occur mid way during the long idle period. |
| default_task_runner_->PostDelayedTask( |
| FROM_HERE, base::Bind(&RecordTimelineTask, base::Unretained(&timeline), |
| - base::Unretained(clock_.get())), |
| + base::Unretained(clock_)), |
| base::TimeDelta::FromMilliseconds(420)); |
| idle_task_runner_->PostIdleTask(FROM_HERE, |
| base::Bind(&TimelineIdleTestTask, &timeline)); |
| @@ -313,7 +314,7 @@ TEST_F(WorkerSchedulerImplTest, |
| // Post a delayed task timed to occur well after the long idle period. |
| default_task_runner_->PostDelayedTask( |
| FROM_HERE, base::Bind(&RecordTimelineTask, base::Unretained(&timeline), |
| - base::Unretained(clock_.get())), |
| + base::Unretained(clock_)), |
| base::TimeDelta::FromMilliseconds(1000)); |
| idle_task_runner_->PostIdleTask(FROM_HERE, |
| base::Bind(&TimelineIdleTestTask, &timeline)); |
| @@ -382,7 +383,7 @@ TEST_F(WorkerSchedulerImplTest, TestLongIdlePeriodTimeline) { |
| // idle period. |
| base::TimeTicks idle_period_deadline = |
| scheduler_->CurrentIdleTaskDeadlineForTesting(); |
| - clock_->AdvanceNow(maximum_idle_period_duration()); |
| + clock_->Advance(maximum_idle_period_duration()); |
| RunUntilIdle(); |
| base::TimeTicks new_idle_period_deadline = |
| @@ -402,7 +403,7 @@ TEST_F(WorkerSchedulerImplTest, TestLongIdlePeriodTimeline) { |
| timeline.push_back("Post RecordTimelineTask"); |
| default_task_runner_->PostTask( |
| FROM_HERE, base::Bind(&RecordTimelineTask, base::Unretained(&timeline), |
| - base::Unretained(clock_.get()))); |
| + base::Unretained(clock_))); |
| RunUntilIdle(); |
| std::string expected_timeline[] = { |