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 "platform/scheduler/base/time_domain.h" | 5 #include "platform/scheduler/base/time_domain.h" |
6 | 6 |
7 #include "base/macros.h" | 7 #include "base/macros.h" |
8 #include "base/memory/ptr_util.h" | 8 #include "base/memory/ptr_util.h" |
9 #include "base/test/simple_test_tick_clock.h" | 9 #include "base/test/simple_test_tick_clock.h" |
10 #include "cc/test/ordered_simple_task_runner.h" | 10 #include "cc/test/ordered_simple_task_runner.h" |
11 #include "platform/scheduler/base/task_queue_impl.h" | 11 #include "platform/scheduler/base/task_queue_impl.h" |
12 #include "platform/scheduler/base/task_queue_manager.h" | 12 #include "platform/scheduler/base/task_queue_manager.h" |
13 #include "platform/scheduler/base/task_queue_manager_delegate_for_test.h" | 13 #include "platform/scheduler/base/task_queue_manager_delegate_for_test.h" |
14 #include "platform/scheduler/base/test_time_source.h" | 14 #include "platform/scheduler/base/test_time_source.h" |
15 #include "platform/scheduler/base/work_queue.h" | 15 #include "platform/scheduler/base/work_queue.h" |
16 #include "testing/gmock/include/gmock/gmock.h" | 16 #include "testing/gmock/include/gmock/gmock.h" |
17 | 17 |
18 using testing::_; | 18 using ::testing::_; |
19 using testing::AnyNumber; | 19 using ::testing::AnyNumber; |
20 using testing::Mock; | 20 using ::testing::Mock; |
21 | 21 |
22 namespace blink { | 22 namespace blink { |
23 namespace scheduler { | 23 namespace scheduler { |
24 | 24 |
25 class MockTimeDomain : public TimeDomain { | 25 class MockTimeDomain : public TimeDomain { |
26 public: | 26 public: |
27 MockTimeDomain() | 27 MockTimeDomain() |
28 : now_(base::TimeTicks() + base::TimeDelta::FromSeconds(1)) {} | 28 : now_(base::TimeTicks() + base::TimeDelta::FromSeconds(1)) {} |
29 | 29 |
30 ~MockTimeDomain() override {} | 30 ~MockTimeDomain() override {} |
(...skipping 26 matching lines...) Expand all Loading... |
57 MOCK_METHOD1(CancelWakeUpAt, void(base::TimeTicks run_time)); | 57 MOCK_METHOD1(CancelWakeUpAt, void(base::TimeTicks run_time)); |
58 | 58 |
59 void SetNow(base::TimeTicks now) { now_ = now; } | 59 void SetNow(base::TimeTicks now) { now_ = now; } |
60 | 60 |
61 private: | 61 private: |
62 base::TimeTicks now_; | 62 base::TimeTicks now_; |
63 | 63 |
64 DISALLOW_COPY_AND_ASSIGN(MockTimeDomain); | 64 DISALLOW_COPY_AND_ASSIGN(MockTimeDomain); |
65 }; | 65 }; |
66 | 66 |
67 class TimeDomainTest : public testing::Test { | 67 class TimeDomainTest : public ::testing::Test { |
68 public: | 68 public: |
69 void SetUp() final { | 69 void SetUp() final { |
70 time_domain_ = base::WrapUnique(CreateMockTimeDomain()); | 70 time_domain_ = base::WrapUnique(CreateMockTimeDomain()); |
71 task_queue_ = make_scoped_refptr(new internal::TaskQueueImpl( | 71 task_queue_ = make_scoped_refptr(new internal::TaskQueueImpl( |
72 nullptr, time_domain_.get(), | 72 nullptr, time_domain_.get(), |
73 TaskQueue::Spec(TaskQueue::QueueType::TEST))); | 73 TaskQueue::Spec(TaskQueue::QueueType::TEST))); |
74 } | 74 } |
75 | 75 |
76 void TearDown() final { | 76 void TearDown() final { |
77 if (task_queue_) | 77 if (task_queue_) |
(...skipping 109 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
187 base::TimeTicks wake_up1 = now + base::TimeDelta::FromMilliseconds(10); | 187 base::TimeTicks wake_up1 = now + base::TimeDelta::FromMilliseconds(10); |
188 EXPECT_CALL(*time_domain_.get(), RequestWakeUpAt(_, wake_up1)).Times(1); | 188 EXPECT_CALL(*time_domain_.get(), RequestWakeUpAt(_, wake_up1)).Times(1); |
189 time_domain_->ScheduleDelayedWork(task_queue_.get(), {wake_up1, 0}, now); | 189 time_domain_->ScheduleDelayedWork(task_queue_.get(), {wake_up1, 0}, now); |
190 base::TimeTicks wake_up2 = now + base::TimeDelta::FromMilliseconds(100); | 190 base::TimeTicks wake_up2 = now + base::TimeDelta::FromMilliseconds(100); |
191 time_domain_->ScheduleDelayedWork(task_queue2_.get(), {wake_up2, 0}, now); | 191 time_domain_->ScheduleDelayedWork(task_queue2_.get(), {wake_up2, 0}, now); |
192 | 192 |
193 TaskQueue* next_task_queue; | 193 TaskQueue* next_task_queue; |
194 EXPECT_TRUE(time_domain_->NextScheduledTaskQueue(&next_task_queue)); | 194 EXPECT_TRUE(time_domain_->NextScheduledTaskQueue(&next_task_queue)); |
195 EXPECT_EQ(task_queue_.get(), next_task_queue); | 195 EXPECT_EQ(task_queue_.get(), next_task_queue); |
196 | 196 |
197 testing::Mock::VerifyAndClearExpectations(time_domain_.get()); | 197 ::testing::Mock::VerifyAndClearExpectations(time_domain_.get()); |
198 | 198 |
199 EXPECT_CALL(*time_domain_.get(), CancelWakeUpAt(wake_up1)).Times(1); | 199 EXPECT_CALL(*time_domain_.get(), CancelWakeUpAt(wake_up1)).Times(1); |
200 EXPECT_CALL(*time_domain_.get(), RequestWakeUpAt(_, wake_up2)).Times(1); | 200 EXPECT_CALL(*time_domain_.get(), RequestWakeUpAt(_, wake_up2)).Times(1); |
201 | 201 |
202 time_domain_->UnregisterQueue(task_queue_.get()); | 202 time_domain_->UnregisterQueue(task_queue_.get()); |
203 task_queue_ = scoped_refptr<internal::TaskQueueImpl>(); | 203 task_queue_ = scoped_refptr<internal::TaskQueueImpl>(); |
204 EXPECT_TRUE(time_domain_->NextScheduledTaskQueue(&next_task_queue)); | 204 EXPECT_TRUE(time_domain_->NextScheduledTaskQueue(&next_task_queue)); |
205 EXPECT_EQ(task_queue2_.get(), next_task_queue); | 205 EXPECT_EQ(task_queue2_.get(), next_task_queue); |
206 | 206 |
207 testing::Mock::VerifyAndClearExpectations(time_domain_.get()); | 207 ::testing::Mock::VerifyAndClearExpectations(time_domain_.get()); |
208 | 208 |
209 EXPECT_CALL(*time_domain_.get(), CancelWakeUpAt(wake_up2)).Times(1); | 209 EXPECT_CALL(*time_domain_.get(), CancelWakeUpAt(wake_up2)).Times(1); |
210 | 210 |
211 time_domain_->UnregisterQueue(task_queue2_.get()); | 211 time_domain_->UnregisterQueue(task_queue2_.get()); |
212 EXPECT_FALSE(time_domain_->NextScheduledTaskQueue(&next_task_queue)); | 212 EXPECT_FALSE(time_domain_->NextScheduledTaskQueue(&next_task_queue)); |
213 } | 213 } |
214 | 214 |
215 TEST_F(TimeDomainTest, WakeUpReadyDelayedQueues) { | 215 TEST_F(TimeDomainTest, WakeUpReadyDelayedQueues) { |
216 base::TimeDelta delay = base::TimeDelta::FromMilliseconds(50); | 216 base::TimeDelta delay = base::TimeDelta::FromMilliseconds(50); |
217 base::TimeTicks now = time_domain_->Now(); | 217 base::TimeTicks now = time_domain_->Now(); |
(...skipping 98 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
316 Mock::VerifyAndClearExpectations(time_domain_.get()); | 316 Mock::VerifyAndClearExpectations(time_domain_.get()); |
317 EXPECT_CALL(*time_domain_.get(), RequestWakeUpAt(_, _)).Times(AnyNumber()); | 317 EXPECT_CALL(*time_domain_.get(), RequestWakeUpAt(_, _)).Times(AnyNumber()); |
318 EXPECT_CALL(*time_domain_.get(), CancelWakeUpAt(_)).Times(AnyNumber()); | 318 EXPECT_CALL(*time_domain_.get(), CancelWakeUpAt(_)).Times(AnyNumber()); |
319 | 319 |
320 // Tidy up. | 320 // Tidy up. |
321 task_queue2->UnregisterTaskQueue(); | 321 task_queue2->UnregisterTaskQueue(); |
322 } | 322 } |
323 | 323 |
324 } // namespace scheduler | 324 } // namespace scheduler |
325 } // namespace blink | 325 } // namespace blink |
OLD | NEW |