| Index: components/offline_pages/background/request_queue_in_memory_store.cc
|
| diff --git a/components/offline_pages/background/request_queue_in_memory_store.cc b/components/offline_pages/background/request_queue_in_memory_store.cc
|
| index 32219a91616eef459ea08ab4fb7116258f781355..ba73580240404926d27a06aa80e23a50b5fa2ba3 100644
|
| --- a/components/offline_pages/background/request_queue_in_memory_store.cc
|
| +++ b/components/offline_pages/background/request_queue_in_memory_store.cc
|
| @@ -4,6 +4,7 @@
|
|
|
| #include "components/offline_pages/background/request_queue_in_memory_store.h"
|
|
|
| +#include <algorithm>
|
| #include <set>
|
|
|
| #include "base/bind.h"
|
| @@ -73,6 +74,27 @@ void RequestQueueInMemoryStore::RemoveRequestsByClientId(
|
| FROM_HERE, base::Bind(callback, true, count));
|
| }
|
|
|
| +void RequestQueueInMemoryStore::ChangeRequestsState(
|
| + const std::vector<int64_t>& request_ids,
|
| + const SavePageRequest::RequestState new_state,
|
| + const UpdateCallback& callback) {
|
| + int count = 0;
|
| +
|
| + for (int64_t request_id : request_ids) {
|
| + auto pair = requests_.find(request_id);
|
| + if (pair != requests_.end()) {
|
| + ++count;
|
| + pair->second.set_request_state(new_state);
|
| + }
|
| + }
|
| +
|
| + RequestQueueStore::UpdateStatus status =
|
| + count > 0 ? UpdateStatus::UPDATED : UpdateStatus::FAILED;
|
| +
|
| + base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE,
|
| + base::Bind(callback, status));
|
| +}
|
| +
|
| void RequestQueueInMemoryStore::Reset(const ResetCallback& callback) {
|
| requests_.clear();
|
| base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE,
|
|
|