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 |