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/child/task_queue_manager.h" | 5 #include "components/scheduler/child/task_queue_manager.h" |
6 | 6 |
7 #include "base/location.h" | 7 #include "base/location.h" |
8 #include "base/run_loop.h" | 8 #include "base/run_loop.h" |
9 #include "base/single_thread_task_runner.h" | 9 #include "base/single_thread_task_runner.h" |
10 #include "base/test/simple_test_tick_clock.h" | 10 #include "base/test/simple_test_tick_clock.h" |
(...skipping 1248 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
1259 std::vector<int> run_order; | 1259 std::vector<int> run_order; |
1260 runners_[0]->PostTask( | 1260 runners_[0]->PostTask( |
1261 FROM_HERE, | 1261 FROM_HERE, |
1262 base::Bind(&PostTestTasksFromNestedMessageLoop, message_loop_.get(), | 1262 base::Bind(&PostTestTasksFromNestedMessageLoop, message_loop_.get(), |
1263 runners_[0], runners_[1], base::Unretained(&run_order))); | 1263 runners_[0], runners_[1], base::Unretained(&run_order))); |
1264 | 1264 |
1265 message_loop_->RunUntilIdle(); | 1265 message_loop_->RunUntilIdle(); |
1266 ASSERT_THAT(run_order, ElementsAre(1)); | 1266 ASSERT_THAT(run_order, ElementsAre(1)); |
1267 } | 1267 } |
1268 | 1268 |
1269 namespace { | |
rmcilroy
2015/09/18 13:15:46
ditto
Sami
2015/09/21 10:52:36
Done.
| |
1270 class MockObserver : public TaskQueueManager::Observer { | |
1271 public: | |
1272 MOCK_METHOD1(OnUnregisterTaskQueue, | |
1273 void(const scoped_refptr<internal::TaskQueueImpl>& queue)); | |
1274 }; | |
1275 } // namespace | |
1276 | |
1277 TEST_F(TaskQueueManagerTest, OnUnregisterTaskQueue) { | |
1278 Initialize(0u); | |
1279 | |
1280 MockObserver observer; | |
1281 manager_->SetObserver(&observer); | |
1282 | |
1283 scoped_refptr<internal::TaskQueueImpl> task_queue = | |
1284 manager_->NewTaskQueue(TaskQueue::Spec("test_queue")); | |
1285 | |
1286 EXPECT_CALL(observer, OnUnregisterTaskQueue(_)).Times(1); | |
1287 task_queue->UnregisterTaskQueue(); | |
1288 | |
1289 manager_->SetObserver(nullptr); | |
1290 } | |
1291 | |
1269 } // namespace scheduler | 1292 } // namespace scheduler |
OLD | NEW |