| 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 "platform/scheduler/child/scheduler_helper.h" | 5 #include "platform/scheduler/child/scheduler_helper.h" |
| 6 | 6 |
| 7 #include "base/callback.h" | 7 #include "base/callback.h" |
| 8 #include "base/macros.h" | 8 #include "base/macros.h" |
| 9 #include "base/memory/ptr_util.h" | 9 #include "base/memory/ptr_util.h" |
| 10 #include "base/test/simple_test_tick_clock.h" | 10 #include "base/test/simple_test_tick_clock.h" |
| (...skipping 119 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 130 EXPECT_TRUE(scheduler_helper_->IsShutdown()); | 130 EXPECT_TRUE(scheduler_helper_->IsShutdown()); |
| 131 } | 131 } |
| 132 | 132 |
| 133 TEST_F(SchedulerHelperTest, DefaultTaskRunnerRegistration) { | 133 TEST_F(SchedulerHelperTest, DefaultTaskRunnerRegistration) { |
| 134 EXPECT_EQ(main_task_runner_->default_task_runner(), | 134 EXPECT_EQ(main_task_runner_->default_task_runner(), |
| 135 scheduler_helper_->DefaultTaskRunner()); | 135 scheduler_helper_->DefaultTaskRunner()); |
| 136 scheduler_helper_->Shutdown(); | 136 scheduler_helper_->Shutdown(); |
| 137 EXPECT_EQ(nullptr, main_task_runner_->default_task_runner()); | 137 EXPECT_EQ(nullptr, main_task_runner_->default_task_runner()); |
| 138 } | 138 } |
| 139 | 139 |
| 140 TEST_F(SchedulerHelperTest, GetNumberOfPendingTasks) { |
| 141 std::vector<std::string> run_order; |
| 142 scheduler_helper_->DefaultTaskRunner()->PostTask( |
| 143 FROM_HERE, base::Bind(&AppendToVectorTestTask, &run_order, "D1")); |
| 144 scheduler_helper_->DefaultTaskRunner()->PostTask( |
| 145 FROM_HERE, base::Bind(&AppendToVectorTestTask, &run_order, "D2")); |
| 146 scheduler_helper_->ControlTaskRunner()->PostTask( |
| 147 FROM_HERE, base::Bind(&AppendToVectorTestTask, &run_order, "C1")); |
| 148 EXPECT_EQ(3U, scheduler_helper_->GetNumberOfPendingTasks()); |
| 149 RunUntilIdle(); |
| 150 EXPECT_EQ(0U, scheduler_helper_->GetNumberOfPendingTasks()); |
| 151 } |
| 152 |
| 140 namespace { | 153 namespace { |
| 141 class MockTaskObserver : public base::MessageLoop::TaskObserver { | 154 class MockTaskObserver : public base::MessageLoop::TaskObserver { |
| 142 public: | 155 public: |
| 143 MOCK_METHOD1(DidProcessTask, void(const base::PendingTask& task)); | 156 MOCK_METHOD1(DidProcessTask, void(const base::PendingTask& task)); |
| 144 MOCK_METHOD1(WillProcessTask, void(const base::PendingTask& task)); | 157 MOCK_METHOD1(WillProcessTask, void(const base::PendingTask& task)); |
| 145 }; | 158 }; |
| 146 | 159 |
| 147 void NopTask() {} | 160 void NopTask() {} |
| 148 } // namespace | 161 } // namespace |
| 149 | 162 |
| (...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 211 task_queue->SetQueueEnabled(false); | 224 task_queue->SetQueueEnabled(false); |
| 212 | 225 |
| 213 EXPECT_CALL(observer, OnTriedToExecuteBlockedTask(_, _)).Times(1); | 226 EXPECT_CALL(observer, OnTriedToExecuteBlockedTask(_, _)).Times(1); |
| 214 RunUntilIdle(); | 227 RunUntilIdle(); |
| 215 | 228 |
| 216 scheduler_helper_->SetObserver(nullptr); | 229 scheduler_helper_->SetObserver(nullptr); |
| 217 } | 230 } |
| 218 | 231 |
| 219 } // namespace scheduler | 232 } // namespace scheduler |
| 220 } // namespace blink | 233 } // namespace blink |
| OLD | NEW |