| 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..9cb1fea9b8f18d5f5443c9001a3d7e5b8dd049cd 100644
|
| --- a/components/offline_pages/background/request_queue_in_memory_store.cc
|
| +++ b/components/offline_pages/background/request_queue_in_memory_store.cc
|
| @@ -4,8 +4,6 @@
|
|
|
| #include "components/offline_pages/background/request_queue_in_memory_store.h"
|
|
|
| -#include <set>
|
| -
|
| #include "base/bind.h"
|
| #include "base/location.h"
|
| #include "base/threading/thread_task_runner_handle.h"
|
| @@ -40,37 +38,21 @@ void RequestQueueInMemoryStore::AddOrUpdateRequest(
|
| void RequestQueueInMemoryStore::RemoveRequests(
|
| const std::vector<int64_t>& request_ids,
|
| const RemoveCallback& callback) {
|
| - int count = 0;
|
| + std::vector<RequestQueue::UpdateRequestResult> results;
|
| RequestsMap::iterator iter;
|
| for (auto request_id : request_ids) {
|
| iter = requests_.find(request_id);
|
| if (iter != requests_.end()) {
|
| requests_.erase(iter);
|
| - ++count;
|
| - }
|
| - }
|
| -
|
| - base::ThreadTaskRunnerHandle::Get()->PostTask(
|
| - FROM_HERE, base::Bind(callback, true, count));
|
| -}
|
| -
|
| -void RequestQueueInMemoryStore::RemoveRequestsByClientId(
|
| - const std::vector<ClientId>& client_ids,
|
| - const RemoveCallback& callback) {
|
| - int count = 0;
|
| -
|
| - std::set<ClientId> client_id_set(client_ids.begin(), client_ids.end());
|
| - for (auto iter = requests_.begin(); iter != requests_.end(); ) {
|
| - if (client_id_set.find(iter->second.client_id()) != client_id_set.end()) {
|
| - requests_.erase(iter++);
|
| - ++count;
|
| + results.push_back(RequestQueue::UpdateRequestResult::SUCCESS);
|
| } else {
|
| - ++iter;
|
| + results.push_back(
|
| + RequestQueue::UpdateRequestResult::REQUEST_DOES_NOT_EXIST);
|
| }
|
| }
|
|
|
| base::ThreadTaskRunnerHandle::Get()->PostTask(
|
| - FROM_HERE, base::Bind(callback, true, count));
|
| + FROM_HERE, base::Bind(callback, request_ids, results));
|
| }
|
|
|
| void RequestQueueInMemoryStore::Reset(const ResetCallback& callback) {
|
|
|