OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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/renderer/renderer_scheduler_impl.h" | 5 #include "components/scheduler/renderer/renderer_scheduler_impl.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/output/begin_frame_args.h" | 9 #include "cc/output/begin_frame_args.h" |
10 #include "cc/test/ordered_simple_task_runner.h" | 10 #include "cc/test/ordered_simple_task_runner.h" |
11 #include "components/scheduler/base/test_time_source.h" | 11 #include "components/scheduler/base/test_time_source.h" |
12 #include "components/scheduler/child/scheduler_task_runner_delegate_for_test.h" | 12 #include "components/scheduler/child/scheduler_tqm_delegate_for_test.h" |
13 #include "components/scheduler/child/scheduler_task_runner_delegate_impl.h" | 13 #include "components/scheduler/child/scheduler_tqm_delegate_impl.h" |
14 #include "testing/gmock/include/gmock/gmock.h" | 14 #include "testing/gmock/include/gmock/gmock.h" |
15 #include "testing/gtest/include/gtest/gtest.h" | 15 #include "testing/gtest/include/gtest/gtest.h" |
16 | 16 |
17 namespace scheduler { | 17 namespace scheduler { |
18 | 18 |
19 namespace { | 19 namespace { |
20 class FakeInputEvent : public blink::WebInputEvent { | 20 class FakeInputEvent : public blink::WebInputEvent { |
21 public: | 21 public: |
22 explicit FakeInputEvent(blink::WebInputEvent::Type event_type) | 22 explicit FakeInputEvent(blink::WebInputEvent::Type event_type) |
23 : WebInputEvent(sizeof(FakeInputEvent)) { | 23 : WebInputEvent(sizeof(FakeInputEvent)) { |
(...skipping 147 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
171 } | 171 } |
172 | 172 |
173 }; // namespace | 173 }; // namespace |
174 | 174 |
175 class RendererSchedulerImplForTest : public RendererSchedulerImpl { | 175 class RendererSchedulerImplForTest : public RendererSchedulerImpl { |
176 public: | 176 public: |
177 using RendererSchedulerImpl::OnIdlePeriodEnded; | 177 using RendererSchedulerImpl::OnIdlePeriodEnded; |
178 using RendererSchedulerImpl::OnIdlePeriodStarted; | 178 using RendererSchedulerImpl::OnIdlePeriodStarted; |
179 | 179 |
180 RendererSchedulerImplForTest( | 180 RendererSchedulerImplForTest( |
181 scoped_refptr<SchedulerTaskRunnerDelegate> main_task_runner) | 181 scoped_refptr<SchedulerTqmDelegate> main_task_runner) |
182 : RendererSchedulerImpl(main_task_runner), update_policy_count_(0) {} | 182 : RendererSchedulerImpl(main_task_runner), update_policy_count_(0) {} |
183 | 183 |
184 void UpdatePolicyLocked(UpdateType update_type) override { | 184 void UpdatePolicyLocked(UpdateType update_type) override { |
185 update_policy_count_++; | 185 update_policy_count_++; |
186 RendererSchedulerImpl::UpdatePolicyLocked(update_type); | 186 RendererSchedulerImpl::UpdatePolicyLocked(update_type); |
187 | 187 |
188 std::string use_case = | 188 std::string use_case = |
189 RendererScheduler::UseCaseToString(MainThreadOnly().current_use_case); | 189 RendererScheduler::UseCaseToString(MainThreadOnly().current_use_case); |
190 if (MainThreadOnly().touchstart_expected_soon) { | 190 if (MainThreadOnly().touchstart_expected_soon) { |
191 use_cases_.push_back(use_case + " scroll expected"); | 191 use_cases_.push_back(use_case + " scroll expected"); |
(...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
229 | 229 |
230 RendererSchedulerImplTest(base::MessageLoop* message_loop) | 230 RendererSchedulerImplTest(base::MessageLoop* message_loop) |
231 : clock_(new base::SimpleTestTickClock()), message_loop_(message_loop) { | 231 : clock_(new base::SimpleTestTickClock()), message_loop_(message_loop) { |
232 clock_->Advance(base::TimeDelta::FromMicroseconds(5000)); | 232 clock_->Advance(base::TimeDelta::FromMicroseconds(5000)); |
233 } | 233 } |
234 | 234 |
235 ~RendererSchedulerImplTest() override {} | 235 ~RendererSchedulerImplTest() override {} |
236 | 236 |
237 void SetUp() override { | 237 void SetUp() override { |
238 if (message_loop_) { | 238 if (message_loop_) { |
239 main_task_runner_ = | 239 main_task_runner_ = SchedulerTqmDelegateImpl::Create( |
240 SchedulerTaskRunnerDelegateImpl::Create(message_loop_.get()); | 240 message_loop_.get(), |
| 241 make_scoped_ptr(new TestTimeSource(clock_.get()))); |
241 } else { | 242 } else { |
242 mock_task_runner_ = make_scoped_refptr( | 243 mock_task_runner_ = make_scoped_refptr( |
243 new cc::OrderedSimpleTaskRunner(clock_.get(), false)); | 244 new cc::OrderedSimpleTaskRunner(clock_.get(), false)); |
244 main_task_runner_ = | 245 main_task_runner_ = SchedulerTqmDelegateForTest::Create( |
245 SchedulerTaskRunnerDelegateForTest::Create(mock_task_runner_); | 246 mock_task_runner_, make_scoped_ptr(new TestTimeSource(clock_.get()))); |
246 } | 247 } |
247 Initialize( | 248 Initialize( |
248 make_scoped_ptr(new RendererSchedulerImplForTest(main_task_runner_))); | 249 make_scoped_ptr(new RendererSchedulerImplForTest(main_task_runner_))); |
249 } | 250 } |
250 | 251 |
251 void Initialize(scoped_ptr<RendererSchedulerImplForTest> scheduler) { | 252 void Initialize(scoped_ptr<RendererSchedulerImplForTest> scheduler) { |
252 scheduler_ = scheduler.Pass(); | 253 scheduler_ = scheduler.Pass(); |
253 default_task_runner_ = scheduler_->DefaultTaskRunner(); | 254 default_task_runner_ = scheduler_->DefaultTaskRunner(); |
254 compositor_task_runner_ = scheduler_->CompositorTaskRunner(); | 255 compositor_task_runner_ = scheduler_->CompositorTaskRunner(); |
255 loading_task_runner_ = scheduler_->LoadingTaskRunner(); | 256 loading_task_runner_ = scheduler_->LoadingTaskRunner(); |
256 idle_task_runner_ = scheduler_->IdleTaskRunner(); | 257 idle_task_runner_ = scheduler_->IdleTaskRunner(); |
257 timer_task_runner_ = scheduler_->TimerTaskRunner(); | 258 timer_task_runner_ = scheduler_->TimerTaskRunner(); |
258 scheduler_->GetSchedulerHelperForTesting()->SetTimeSourceForTesting( | |
259 make_scoped_ptr(new TestTimeSource(clock_.get()))); | |
260 scheduler_->GetSchedulerHelperForTesting() | |
261 ->GetTaskQueueManagerForTesting() | |
262 ->SetTimeSourceForTesting( | |
263 make_scoped_ptr(new TestTimeSource(clock_.get()))); | |
264 scheduler_->GetLoadingTaskCostEstimatorForTesting() | |
265 ->SetTimeSourceForTesting( | |
266 make_scoped_ptr(new TestTimeSource(clock_.get()))); | |
267 scheduler_->GetTimerTaskCostEstimatorForTesting()->SetTimeSourceForTesting( | |
268 make_scoped_ptr(new TestTimeSource(clock_.get()))); | |
269 scheduler_->GetIdleTimeEstimatorForTesting()->SetTimeSourceForTesting( | |
270 make_scoped_ptr(new TestTimeSource(clock_.get()))); | |
271 } | 259 } |
272 | 260 |
273 void TearDown() override { | 261 void TearDown() override { |
274 DCHECK(!mock_task_runner_.get() || !message_loop_.get()); | 262 DCHECK(!mock_task_runner_.get() || !message_loop_.get()); |
275 scheduler_->Shutdown(); | 263 scheduler_->Shutdown(); |
276 if (mock_task_runner_.get()) { | 264 if (mock_task_runner_.get()) { |
277 // Check that all tests stop posting tasks. | 265 // Check that all tests stop posting tasks. |
278 mock_task_runner_->SetAutoAdvanceNowToPendingTasks(true); | 266 mock_task_runner_->SetAutoAdvanceNowToPendingTasks(true); |
279 while (mock_task_runner_->RunUntilIdle()) { | 267 while (mock_task_runner_->RunUntilIdle()) { |
280 } | 268 } |
(...skipping 198 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
479 RendererSchedulerImpl::UseCase::FIRST_USE_CASE, | 467 RendererSchedulerImpl::UseCase::FIRST_USE_CASE, |
480 RendererSchedulerImpl::UseCase::USE_CASE_COUNT, | 468 RendererSchedulerImpl::UseCase::USE_CASE_COUNT, |
481 &RendererSchedulerImpl::UseCaseToString); | 469 &RendererSchedulerImpl::UseCaseToString); |
482 } | 470 } |
483 | 471 |
484 scoped_ptr<base::SimpleTestTickClock> clock_; | 472 scoped_ptr<base::SimpleTestTickClock> clock_; |
485 // Only one of mock_task_runner_ or message_loop_ will be set. | 473 // Only one of mock_task_runner_ or message_loop_ will be set. |
486 scoped_refptr<cc::OrderedSimpleTaskRunner> mock_task_runner_; | 474 scoped_refptr<cc::OrderedSimpleTaskRunner> mock_task_runner_; |
487 scoped_ptr<base::MessageLoop> message_loop_; | 475 scoped_ptr<base::MessageLoop> message_loop_; |
488 | 476 |
489 scoped_refptr<SchedulerTaskRunnerDelegate> main_task_runner_; | 477 scoped_refptr<SchedulerTqmDelegate> main_task_runner_; |
490 scoped_ptr<RendererSchedulerImplForTest> scheduler_; | 478 scoped_ptr<RendererSchedulerImplForTest> scheduler_; |
491 scoped_refptr<base::SingleThreadTaskRunner> default_task_runner_; | 479 scoped_refptr<base::SingleThreadTaskRunner> default_task_runner_; |
492 scoped_refptr<base::SingleThreadTaskRunner> compositor_task_runner_; | 480 scoped_refptr<base::SingleThreadTaskRunner> compositor_task_runner_; |
493 scoped_refptr<base::SingleThreadTaskRunner> loading_task_runner_; | 481 scoped_refptr<base::SingleThreadTaskRunner> loading_task_runner_; |
494 scoped_refptr<SingleThreadIdleTaskRunner> idle_task_runner_; | 482 scoped_refptr<SingleThreadIdleTaskRunner> idle_task_runner_; |
495 scoped_refptr<base::SingleThreadTaskRunner> timer_task_runner_; | 483 scoped_refptr<base::SingleThreadTaskRunner> timer_task_runner_; |
496 bool simulate_timer_task_ran_; | 484 bool simulate_timer_task_ran_; |
497 | 485 |
498 DISALLOW_COPY_AND_ASSIGN(RendererSchedulerImplTest); | 486 DISALLOW_COPY_AND_ASSIGN(RendererSchedulerImplTest); |
499 }; | 487 }; |
(...skipping 861 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1361 RunUntilIdle(); | 1349 RunUntilIdle(); |
1362 EXPECT_EQ(UseCase::NONE, CurrentUseCase()); | 1350 EXPECT_EQ(UseCase::NONE, CurrentUseCase()); |
1363 } | 1351 } |
1364 | 1352 |
1365 class RendererSchedulerImplWithMockSchedulerTest | 1353 class RendererSchedulerImplWithMockSchedulerTest |
1366 : public RendererSchedulerImplTest { | 1354 : public RendererSchedulerImplTest { |
1367 public: | 1355 public: |
1368 void SetUp() override { | 1356 void SetUp() override { |
1369 mock_task_runner_ = make_scoped_refptr( | 1357 mock_task_runner_ = make_scoped_refptr( |
1370 new cc::OrderedSimpleTaskRunner(clock_.get(), false)); | 1358 new cc::OrderedSimpleTaskRunner(clock_.get(), false)); |
1371 main_task_runner_ = | 1359 main_task_runner_ = SchedulerTqmDelegateForTest::Create( |
1372 SchedulerTaskRunnerDelegateForTest::Create(mock_task_runner_); | 1360 mock_task_runner_, make_scoped_ptr(new TestTimeSource(clock_.get()))); |
1373 mock_scheduler_ = new RendererSchedulerImplForTest(main_task_runner_); | 1361 mock_scheduler_ = new RendererSchedulerImplForTest(main_task_runner_); |
1374 Initialize(make_scoped_ptr(mock_scheduler_)); | 1362 Initialize(make_scoped_ptr(mock_scheduler_)); |
1375 } | 1363 } |
1376 | 1364 |
1377 protected: | 1365 protected: |
1378 RendererSchedulerImplForTest* mock_scheduler_; | 1366 RendererSchedulerImplForTest* mock_scheduler_; |
1379 }; | 1367 }; |
1380 | 1368 |
1381 TEST_F(RendererSchedulerImplWithMockSchedulerTest, | 1369 TEST_F(RendererSchedulerImplWithMockSchedulerTest, |
1382 OnlyOnePendingUrgentPolicyUpdatey) { | 1370 OnlyOnePendingUrgentPolicyUpdatey) { |
(...skipping 843 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2226 } | 2214 } |
2227 | 2215 |
2228 base::TimeDelta time_till_next_frame = | 2216 base::TimeDelta time_till_next_frame = |
2229 EstimatedNextFrameBegin() - clock_->NowTicks(); | 2217 EstimatedNextFrameBegin() - clock_->NowTicks(); |
2230 if (time_till_next_frame > base::TimeDelta()) | 2218 if (time_till_next_frame > base::TimeDelta()) |
2231 clock_->Advance(time_till_next_frame); | 2219 clock_->Advance(time_till_next_frame); |
2232 } | 2220 } |
2233 } | 2221 } |
2234 | 2222 |
2235 } // namespace scheduler | 2223 } // namespace scheduler |
OLD | NEW |