| 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 <utility> | 7 #include <utility> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/callback.h" | 10 #include "base/callback.h" |
| (...skipping 296 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 307 } | 307 } |
| 308 } | 308 } |
| 309 | 309 |
| 310 if (available_user_request) | 310 if (available_user_request) |
| 311 StartProcessingIfConnected(); | 311 StartProcessingIfConnected(); |
| 312 } | 312 } |
| 313 | 313 |
| 314 void RequestCoordinator::HandleRemovedRequestsAndCallback( | 314 void RequestCoordinator::HandleRemovedRequestsAndCallback( |
| 315 const RemoveRequestsCallback& callback, | 315 const RemoveRequestsCallback& callback, |
| 316 BackgroundSavePageResult status, | 316 BackgroundSavePageResult status, |
| 317 const RequestQueue::UpdateMultipleRequestResults& results, | 317 std::unique_ptr<UpdateRequestsResult> result) { |
| 318 std::vector<std::unique_ptr<SavePageRequest>> requests) { | 318 callback.Run(result->item_statuses); |
| 319 callback.Run(results); | 319 HandleRemovedRequests(status, std::move(result)); |
| 320 HandleRemovedRequests(status, results, std::move(requests)); | |
| 321 } | 320 } |
| 322 | 321 |
| 323 void RequestCoordinator::HandleRemovedRequests( | 322 void RequestCoordinator::HandleRemovedRequests( |
| 324 BackgroundSavePageResult status, | 323 BackgroundSavePageResult status, |
| 325 const RequestQueue::UpdateMultipleRequestResults& results, | 324 std::unique_ptr<UpdateRequestsResult> result) { |
| 326 std::vector<std::unique_ptr<SavePageRequest>> requests) { | 325 for (const auto& request : result->updated_items) |
| 327 for (const auto& request : requests) | 326 NotifyCompleted(request, status); |
| 328 NotifyCompleted(*request, status); | |
| 329 } | 327 } |
| 330 | 328 |
| 331 void RequestCoordinator::ScheduleAsNeeded() { | 329 void RequestCoordinator::ScheduleAsNeeded() { |
| 332 // Get all requests from queue (there is no filtering mechanism). | 330 // Get all requests from queue (there is no filtering mechanism). |
| 333 queue_->GetRequests( | 331 queue_->GetRequests( |
| 334 base::Bind(&RequestCoordinator::GetRequestsForSchedulingCallback, | 332 base::Bind(&RequestCoordinator::GetRequestsForSchedulingCallback, |
| 335 weak_ptr_factory_.GetWeakPtr())); | 333 weak_ptr_factory_.GetWeakPtr())); |
| 336 } | 334 } |
| 337 | 335 |
| 338 void RequestCoordinator::StopProcessing() { | 336 void RequestCoordinator::StopProcessing() { |
| (...skipping 260 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 599 if (!offliner_) { | 597 if (!offliner_) { |
| 600 offliner_ = factory_->GetOffliner(policy_.get()); | 598 offliner_ = factory_->GetOffliner(policy_.get()); |
| 601 } | 599 } |
| 602 } | 600 } |
| 603 | 601 |
| 604 void RequestCoordinator::Shutdown() { | 602 void RequestCoordinator::Shutdown() { |
| 605 network_quality_estimator_ = nullptr; | 603 network_quality_estimator_ = nullptr; |
| 606 } | 604 } |
| 607 | 605 |
| 608 } // namespace offline_pages | 606 } // namespace offline_pages |
| OLD | NEW |