| 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 "content/renderer/scheduler/task_queue_manager.h" | 5 #include "content/renderer/scheduler/task_queue_manager.h" |
| 6 | 6 |
| 7 #include "base/test/test_simple_task_runner.h" | 7 #include "base/test/test_simple_task_runner.h" |
| 8 #include "base/threading/thread.h" | 8 #include "base/threading/thread.h" |
| 9 #include "content/renderer/scheduler/task_queue_selector.h" | 9 #include "content/renderer/scheduler/task_queue_selector.h" |
| 10 #include "testing/gtest/include/gtest/gtest.h" | 10 #include "testing/gtest/include/gtest/gtest.h" |
| (...skipping 19 matching lines...) Expand all Loading... |
| 30 } | 30 } |
| 31 | 31 |
| 32 void AppendQueueToService(size_t queue_index) { | 32 void AppendQueueToService(size_t queue_index) { |
| 33 queues_to_service_.push_back(queue_index); | 33 queues_to_service_.push_back(queue_index); |
| 34 } | 34 } |
| 35 | 35 |
| 36 const std::vector<const base::TaskQueue*>& work_queues() { | 36 const std::vector<const base::TaskQueue*>& work_queues() { |
| 37 return work_queues_; | 37 return work_queues_; |
| 38 } | 38 } |
| 39 | 39 |
| 40 void AsValueInto(base::debug::TracedValue* state) const override { |
| 41 } |
| 42 |
| 40 private: | 43 private: |
| 41 std::deque<size_t> queues_to_service_; | 44 std::deque<size_t> queues_to_service_; |
| 42 std::vector<const base::TaskQueue*> work_queues_; | 45 std::vector<const base::TaskQueue*> work_queues_; |
| 43 | 46 |
| 44 DISALLOW_COPY_AND_ASSIGN(SelectorForTest); | 47 DISALLOW_COPY_AND_ASSIGN(SelectorForTest); |
| 45 }; | 48 }; |
| 46 | 49 |
| 47 class TaskQueueManagerTest : public testing::Test { | 50 class TaskQueueManagerTest : public testing::Test { |
| 48 protected: | 51 protected: |
| 49 void Initialize(size_t num_queues) { | 52 void Initialize(size_t num_queues) { |
| (...skipping 299 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 349 FROM_HERE, base::Bind(&PostTaskToRunner, runner, &run_order)); | 352 FROM_HERE, base::Bind(&PostTaskToRunner, runner, &run_order)); |
| 350 thread.Stop(); | 353 thread.Stop(); |
| 351 | 354 |
| 352 selector_->AppendQueueToService(0); | 355 selector_->AppendQueueToService(0); |
| 353 message_loop.RunUntilIdle(); | 356 message_loop.RunUntilIdle(); |
| 354 EXPECT_EQ(1, run_order[0]); | 357 EXPECT_EQ(1, run_order[0]); |
| 355 } | 358 } |
| 356 | 359 |
| 357 } // namespace | 360 } // namespace |
| 358 } // namespace content | 361 } // namespace content |
| OLD | NEW |