| Index: components/offline_pages/core/background/request_queue.cc
|
| diff --git a/components/offline_pages/core/background/request_queue.cc b/components/offline_pages/core/background/request_queue.cc
|
| index 775803569f505f88cd83a0c9e516d35bfe5f78b1..406f0ae0ce4cc084756959fbc2680818253b07ab 100644
|
| --- a/components/offline_pages/core/background/request_queue.cc
|
| +++ b/components/offline_pages/core/background/request_queue.cc
|
| @@ -17,6 +17,7 @@
|
| #include "components/offline_pages/core/background/mark_attempt_completed_task.h"
|
| #include "components/offline_pages/core/background/mark_attempt_started_task.h"
|
| #include "components/offline_pages/core/background/pick_request_task.h"
|
| +#include "components/offline_pages/core/background/reconcile_task.h"
|
| #include "components/offline_pages/core/background/remove_requests_task.h"
|
| #include "components/offline_pages/core/background/request_queue_store.h"
|
| #include "components/offline_pages/core/background/save_page_request.h"
|
| @@ -138,6 +139,13 @@ void RequestQueue::PickNextRequest(
|
| task_queue_.AddTask(std::move(task));
|
| }
|
|
|
| +void RequestQueue::ReconcileRequests(const UpdateCallback& callback) {
|
| + std::unique_ptr<Task> task(new ReconcileTask(store_.get(), callback));
|
| +
|
| + // Queue up the reconcile task.
|
| + task_queue_.AddTask(std::move(task));
|
| +}
|
| +
|
| void RequestQueue::CleanupRequestQueue() {
|
| // Create a cleanup task.
|
| std::unique_ptr<Task> task(cleanup_factory_->CreateCleanupTask(store_.get()));
|
|
|