| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "components/scheduler/child/idle_helper.h" | 5 #include "components/scheduler/child/idle_helper.h" |
| 6 | 6 |
| 7 #include "base/callback.h" | 7 #include "base/callback.h" |
| 8 #include "base/test/simple_test_tick_clock.h" | 8 #include "base/test/simple_test_tick_clock.h" |
| 9 #include "cc/test/ordered_simple_task_runner.h" | 9 #include "cc/test/ordered_simple_task_runner.h" |
| 10 #include "components/scheduler/base/task_queue.h" | 10 #include "components/scheduler/base/task_queue.h" |
| 11 #include "components/scheduler/base/task_queue_manager.h" | 11 #include "components/scheduler/base/task_queue_manager.h" |
| 12 #include "components/scheduler/base/test_time_source.h" | 12 #include "components/scheduler/base/test_time_source.h" |
| 13 #include "components/scheduler/child/scheduler_helper.h" | 13 #include "components/scheduler/child/scheduler_helper.h" |
| 14 #include "components/scheduler/child/scheduler_task_runner_delegate_for_test.h" | 14 #include "components/scheduler/child/scheduler_tqm_delegate_for_test.h" |
| 15 #include "components/scheduler/child/scheduler_task_runner_delegate_impl.h" | 15 #include "components/scheduler/child/scheduler_tqm_delegate_impl.h" |
| 16 #include "testing/gmock/include/gmock/gmock.h" | 16 #include "testing/gmock/include/gmock/gmock.h" |
| 17 #include "testing/gtest/include/gtest/gtest.h" | 17 #include "testing/gtest/include/gtest/gtest.h" |
| 18 | 18 |
| 19 using testing::_; | 19 using testing::_; |
| 20 using testing::AnyNumber; | 20 using testing::AnyNumber; |
| 21 using testing::AtLeast; | 21 using testing::AtLeast; |
| 22 using testing::Exactly; | 22 using testing::Exactly; |
| 23 using testing::Invoke; | 23 using testing::Invoke; |
| 24 using testing::Return; | 24 using testing::Return; |
| 25 | 25 |
| (...skipping 93 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 119 void UpdateClockToDeadlineIdleTestTask(base::SimpleTestTickClock* clock, | 119 void UpdateClockToDeadlineIdleTestTask(base::SimpleTestTickClock* clock, |
| 120 int* run_count, | 120 int* run_count, |
| 121 base::TimeTicks deadline) { | 121 base::TimeTicks deadline) { |
| 122 UpdateClockIdleTestTask(clock, run_count, deadline, deadline); | 122 UpdateClockIdleTestTask(clock, run_count, deadline, deadline); |
| 123 } | 123 } |
| 124 | 124 |
| 125 void EndIdlePeriodIdleTask(IdleHelper* idle_helper, base::TimeTicks deadline) { | 125 void EndIdlePeriodIdleTask(IdleHelper* idle_helper, base::TimeTicks deadline) { |
| 126 idle_helper->EndIdlePeriod(); | 126 idle_helper->EndIdlePeriod(); |
| 127 } | 127 } |
| 128 | 128 |
| 129 scoped_refptr<SchedulerTaskRunnerDelegate> CreateTaskRunnerDelegate( | 129 scoped_refptr<SchedulerTqmDelegate> CreateTaskRunnerDelegate( |
| 130 base::MessageLoop* message_loop, | 130 base::MessageLoop* message_loop, |
| 131 scoped_refptr<cc::OrderedSimpleTaskRunner> mock_task_runner) { | 131 scoped_refptr<cc::OrderedSimpleTaskRunner> mock_task_runner, |
| 132 scoped_ptr<TestTimeSource> test_time_source) { |
| 132 if (message_loop) | 133 if (message_loop) |
| 133 return SchedulerTaskRunnerDelegateImpl::Create(message_loop); | 134 return SchedulerTqmDelegateImpl::Create(message_loop, |
| 135 test_time_source.Pass()); |
| 134 | 136 |
| 135 return SchedulerTaskRunnerDelegateForTest::Create(mock_task_runner); | 137 return SchedulerTqmDelegateForTest::Create(mock_task_runner, |
| 138 test_time_source.Pass()); |
| 136 } | 139 } |
| 137 | 140 |
| 138 }; // namespace | 141 }; // namespace |
| 139 | 142 |
| 140 class IdleHelperForTest : public IdleHelper, public IdleHelper::Delegate { | 143 class IdleHelperForTest : public IdleHelper, public IdleHelper::Delegate { |
| 141 public: | 144 public: |
| 142 explicit IdleHelperForTest( | 145 explicit IdleHelperForTest( |
| 143 SchedulerHelper* scheduler_helper, | 146 SchedulerHelper* scheduler_helper, |
| 144 base::TimeDelta required_quiescence_duration_before_long_idle_period) | 147 base::TimeDelta required_quiescence_duration_before_long_idle_period) |
| 145 : IdleHelper(scheduler_helper, | 148 : IdleHelper(scheduler_helper, |
| (...skipping 19 matching lines...) Expand all Loading... |
| 165 public: | 168 public: |
| 166 BaseIdleHelperTest( | 169 BaseIdleHelperTest( |
| 167 base::MessageLoop* message_loop, | 170 base::MessageLoop* message_loop, |
| 168 base::TimeDelta required_quiescence_duration_before_long_idle_period) | 171 base::TimeDelta required_quiescence_duration_before_long_idle_period) |
| 169 : clock_(new base::SimpleTestTickClock()), | 172 : clock_(new base::SimpleTestTickClock()), |
| 170 mock_task_runner_( | 173 mock_task_runner_( |
| 171 message_loop | 174 message_loop |
| 172 ? nullptr | 175 ? nullptr |
| 173 : new cc::OrderedSimpleTaskRunner(clock_.get(), false)), | 176 : new cc::OrderedSimpleTaskRunner(clock_.get(), false)), |
| 174 message_loop_(message_loop), | 177 message_loop_(message_loop), |
| 175 main_task_runner_( | 178 main_task_runner_(CreateTaskRunnerDelegate( |
| 176 CreateTaskRunnerDelegate(message_loop, mock_task_runner_)), | 179 message_loop, |
| 180 mock_task_runner_, |
| 181 make_scoped_ptr(new TestTimeSource(clock_.get())))), |
| 177 scheduler_helper_( | 182 scheduler_helper_( |
| 178 new SchedulerHelper(main_task_runner_, | 183 new SchedulerHelper(main_task_runner_, |
| 179 "test.idle", | 184 "test.idle", |
| 180 TRACE_DISABLED_BY_DEFAULT("test.idle"), | 185 TRACE_DISABLED_BY_DEFAULT("test.idle"), |
| 181 TRACE_DISABLED_BY_DEFAULT("test.idle.debug"))), | 186 TRACE_DISABLED_BY_DEFAULT("test.idle.debug"))), |
| 182 idle_helper_(new IdleHelperForTest( | 187 idle_helper_(new IdleHelperForTest( |
| 183 scheduler_helper_.get(), | 188 scheduler_helper_.get(), |
| 184 required_quiescence_duration_before_long_idle_period)), | 189 required_quiescence_duration_before_long_idle_period)), |
| 185 default_task_runner_(scheduler_helper_->DefaultTaskRunner()), | 190 default_task_runner_(scheduler_helper_->DefaultTaskRunner()), |
| 186 idle_task_runner_(idle_helper_->IdleTaskRunner()) { | 191 idle_task_runner_(idle_helper_->IdleTaskRunner()) { |
| 187 clock_->Advance(base::TimeDelta::FromMicroseconds(5000)); | 192 clock_->Advance(base::TimeDelta::FromMicroseconds(5000)); |
| 188 scheduler_helper_->SetTimeSourceForTesting( | |
| 189 make_scoped_ptr(new TestTimeSource(clock_.get()))); | |
| 190 scheduler_helper_->GetTaskQueueManagerForTesting()->SetTimeSourceForTesting( | |
| 191 make_scoped_ptr(new TestTimeSource(clock_.get()))); | |
| 192 } | 193 } |
| 193 | 194 |
| 194 ~BaseIdleHelperTest() override {} | 195 ~BaseIdleHelperTest() override {} |
| 195 | 196 |
| 196 void SetUp() override { | 197 void SetUp() override { |
| 197 EXPECT_CALL(*idle_helper_, OnIdlePeriodStarted()).Times(AnyNumber()); | 198 EXPECT_CALL(*idle_helper_, OnIdlePeriodStarted()).Times(AnyNumber()); |
| 198 EXPECT_CALL(*idle_helper_, OnIdlePeriodEnded()).Times(AnyNumber()); | 199 EXPECT_CALL(*idle_helper_, OnIdlePeriodEnded()).Times(AnyNumber()); |
| 199 EXPECT_CALL(*idle_helper_, CanEnterLongIdlePeriod(_, _)) | 200 EXPECT_CALL(*idle_helper_, CanEnterLongIdlePeriod(_, _)) |
| 200 .Times(AnyNumber()) | 201 .Times(AnyNumber()) |
| 201 .WillRepeatedly(Return(true)); | 202 .WillRepeatedly(Return(true)); |
| (...skipping 65 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 267 void CheckIdlePeriodStateIs(const char* expected) { | 268 void CheckIdlePeriodStateIs(const char* expected) { |
| 268 EXPECT_STREQ(expected, IdleHelper::IdlePeriodStateToString( | 269 EXPECT_STREQ(expected, IdleHelper::IdlePeriodStateToString( |
| 269 idle_helper_->SchedulerIdlePeriodState())); | 270 idle_helper_->SchedulerIdlePeriodState())); |
| 270 } | 271 } |
| 271 | 272 |
| 272 scoped_ptr<base::SimpleTestTickClock> clock_; | 273 scoped_ptr<base::SimpleTestTickClock> clock_; |
| 273 // Only one of mock_task_runner_ or message_loop_ will be set. | 274 // Only one of mock_task_runner_ or message_loop_ will be set. |
| 274 scoped_refptr<cc::OrderedSimpleTaskRunner> mock_task_runner_; | 275 scoped_refptr<cc::OrderedSimpleTaskRunner> mock_task_runner_; |
| 275 scoped_ptr<base::MessageLoop> message_loop_; | 276 scoped_ptr<base::MessageLoop> message_loop_; |
| 276 | 277 |
| 277 scoped_refptr<SchedulerTaskRunnerDelegate> main_task_runner_; | 278 scoped_refptr<SchedulerTqmDelegate> main_task_runner_; |
| 278 scoped_ptr<SchedulerHelper> scheduler_helper_; | 279 scoped_ptr<SchedulerHelper> scheduler_helper_; |
| 279 scoped_ptr<IdleHelperForTest> idle_helper_; | 280 scoped_ptr<IdleHelperForTest> idle_helper_; |
| 280 scoped_refptr<base::SingleThreadTaskRunner> default_task_runner_; | 281 scoped_refptr<base::SingleThreadTaskRunner> default_task_runner_; |
| 281 scoped_refptr<SingleThreadIdleTaskRunner> idle_task_runner_; | 282 scoped_refptr<SingleThreadIdleTaskRunner> idle_task_runner_; |
| 282 | 283 |
| 283 DISALLOW_COPY_AND_ASSIGN(BaseIdleHelperTest); | 284 DISALLOW_COPY_AND_ASSIGN(BaseIdleHelperTest); |
| 284 }; | 285 }; |
| 285 | 286 |
| 286 class IdleHelperTest : public BaseIdleHelperTest { | 287 class IdleHelperTest : public BaseIdleHelperTest { |
| 287 public: | 288 public: |
| (...skipping 847 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1135 EXPECT_EQ(0, run_count); | 1136 EXPECT_EQ(0, run_count); |
| 1136 | 1137 |
| 1137 default_task_runner_->PostDelayedTask(FROM_HERE, base::Bind(&NullTask), | 1138 default_task_runner_->PostDelayedTask(FROM_HERE, base::Bind(&NullTask), |
| 1138 more_than_min_deadline_duration); | 1139 more_than_min_deadline_duration); |
| 1139 idle_helper_->EnableLongIdlePeriod(); | 1140 idle_helper_->EnableLongIdlePeriod(); |
| 1140 RunUntilIdle(); | 1141 RunUntilIdle(); |
| 1141 EXPECT_EQ(1, run_count); | 1142 EXPECT_EQ(1, run_count); |
| 1142 } | 1143 } |
| 1143 | 1144 |
| 1144 } // namespace scheduler | 1145 } // namespace scheduler |
| OLD | NEW |