| OLD | NEW |
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 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/offline_pages/background/request_coordinator.h" | 5 #include "components/offline_pages/background/request_coordinator.h" |
| 6 | 6 |
| 7 #include <memory> | 7 #include <memory> |
| 8 #include <utility> | 8 #include <utility> |
| 9 #include <vector> | 9 #include <vector> |
| 10 | 10 |
| (...skipping 290 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 301 void RequestCoordinatorTest::SetUp() { | 301 void RequestCoordinatorTest::SetUp() { |
| 302 std::unique_ptr<OfflinerPolicy> policy(new OfflinerPolicy()); | 302 std::unique_ptr<OfflinerPolicy> policy(new OfflinerPolicy()); |
| 303 std::unique_ptr<OfflinerFactory> factory(new OfflinerFactoryStub()); | 303 std::unique_ptr<OfflinerFactory> factory(new OfflinerFactoryStub()); |
| 304 // Save the offliner for use by the tests. | 304 // Save the offliner for use by the tests. |
| 305 offliner_ = | 305 offliner_ = |
| 306 reinterpret_cast<OfflinerStub*>(factory->GetOffliner(policy.get())); | 306 reinterpret_cast<OfflinerStub*>(factory->GetOffliner(policy.get())); |
| 307 std::unique_ptr<RequestQueueInMemoryStore> | 307 std::unique_ptr<RequestQueueInMemoryStore> |
| 308 store(new RequestQueueInMemoryStore()); | 308 store(new RequestQueueInMemoryStore()); |
| 309 std::unique_ptr<RequestQueue> queue(new RequestQueue(std::move(store))); | 309 std::unique_ptr<RequestQueue> queue(new RequestQueue(std::move(store))); |
| 310 std::unique_ptr<Scheduler> scheduler_stub(new SchedulerStub()); | 310 std::unique_ptr<Scheduler> scheduler_stub(new SchedulerStub()); |
| 311 // TODO(dougarnett): Add NetworkQualityProvider and tests for its use. |
| 312 std::unique_ptr<net::NetworkQualityEstimator::NetworkQualityProvider> nqe( |
| 313 nullptr); |
| 311 coordinator_.reset(new RequestCoordinator( | 314 coordinator_.reset(new RequestCoordinator( |
| 312 std::move(policy), std::move(factory), std::move(queue), | 315 std::move(policy), std::move(factory), std::move(queue), |
| 313 std::move(scheduler_stub))); | 316 std::move(scheduler_stub), std::move(nqe))); |
| 314 coordinator_->AddObserver(&observer_); | 317 coordinator_->AddObserver(&observer_); |
| 315 } | 318 } |
| 316 | 319 |
| 317 void RequestCoordinatorTest::PumpLoop() { | 320 void RequestCoordinatorTest::PumpLoop() { |
| 318 task_runner_->RunUntilIdle(); | 321 task_runner_->RunUntilIdle(); |
| 319 } | 322 } |
| 320 | 323 |
| 321 void RequestCoordinatorTest::GetRequestsDone( | 324 void RequestCoordinatorTest::GetRequestsDone( |
| 322 RequestQueue::GetRequestsResult result, | 325 RequestQueue::GetRequestsResult result, |
| 323 std::vector<std::unique_ptr<SavePageRequest>> requests) { | 326 std::vector<std::unique_ptr<SavePageRequest>> requests) { |
| (...skipping 701 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1025 // Now whether processing triggered immediately depends on whether test | 1028 // Now whether processing triggered immediately depends on whether test |
| 1026 // is run on svelte device or not. | 1029 // is run on svelte device or not. |
| 1027 if (base::SysInfo::IsLowEndDevice()) { | 1030 if (base::SysInfo::IsLowEndDevice()) { |
| 1028 EXPECT_FALSE(is_busy()); | 1031 EXPECT_FALSE(is_busy()); |
| 1029 } else { | 1032 } else { |
| 1030 EXPECT_TRUE(is_busy()); | 1033 EXPECT_TRUE(is_busy()); |
| 1031 } | 1034 } |
| 1032 } | 1035 } |
| 1033 | 1036 |
| 1034 } // namespace offline_pages | 1037 } // namespace offline_pages |
| OLD | NEW |