| 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 |