Request Picker task

components/offline_pages/background/request_queue_in_memory_store.cc

 // Copyright 2016 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "components/offline_pages/background/request_queue_in_memory_store.h"
 
 #include <unordered_set>
 
 #include "base/bind.h"
 #include "base/location.h"
@@ skipping 15 matching lines @@
     result_requests.push_back(std::move(request));
   }
   base::ThreadTaskRunnerHandle::Get()->PostTask(
       FROM_HERE,
       base::Bind(callback, true, base::Passed(std::move(result_requests))));
 }
 
 void RequestQueueInMemoryStore::GetRequestsByIds(
     const std::vector<int64_t>& request_ids,
     const UpdateCallback& callback) {
-  std::unique_ptr<UpdateRequestsResult> result(
-      new UpdateRequestsResult(state()));
+  std::unique_ptr<QueueResults::UpdateRequestsResult> result(
+      new QueueResults::UpdateRequestsResult(state()));
 
   ItemActionStatus status;
   // Make sure not to include the same request multiple times, while preserving
   // the order of non-duplicated IDs in the result.
   std::unordered_set<int64_t> processed_ids;
   for (const auto& request_id : request_ids) {
     if (!processed_ids.insert(request_id).second)
       continue;
     RequestsMap::iterator iter = requests_.find(request_id);
     if (iter != requests_.end()) {
@@ skipping 20 matching lines @@
     status = ItemActionStatus::ALREADY_EXISTS;
   }
 
   base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE,
                                                 base::Bind(callback, status));
 }
 
 void RequestQueueInMemoryStore::UpdateRequests(
     const std::vector<SavePageRequest>& requests,
     const RequestQueue::UpdateCallback& callback) {
-  std::unique_ptr<UpdateRequestsResult> result(
-      new UpdateRequestsResult(state()));
+  std::unique_ptr<QueueResults::UpdateRequestsResult> result(
+      new QueueResults::UpdateRequestsResult(state()));
 
   ItemActionStatus status;
   for (const auto& request : requests) {
     RequestsMap::iterator iter = requests_.find(request.request_id());
     if (iter != requests_.end()) {
       status = ItemActionStatus::SUCCESS;
       iter->second = request;
       result->updated_items.push_back(request);
     } else {
       status = ItemActionStatus::NOT_FOUND;
     }
     result->item_statuses.push_back(
         std::make_pair(request.request_id(), status));
   }
 
   base::ThreadTaskRunnerHandle::Get()->PostTask(
       FROM_HERE, base::Bind(callback, base::Passed(&result)));
 }
 
 void RequestQueueInMemoryStore::RemoveRequests(
     const std::vector<int64_t>& request_ids,
     const UpdateCallback& callback) {
-  std::unique_ptr<UpdateRequestsResult> result(
-      new UpdateRequestsResult(StoreState::LOADED));
+  std::unique_ptr<QueueResults::UpdateRequestsResult> result(
+      new QueueResults::UpdateRequestsResult(StoreState::LOADED));
 
   ItemActionStatus status;
   // If we find a request, mark it as succeeded, and put it in the request list.
   // Otherwise mark it as failed.
   for (auto request_id : request_ids) {
     RequestsMap::iterator iter = requests_.find(request_id);
     if (iter != requests_.end()) {
       status = ItemActionStatus::SUCCESS;
       result->updated_items.push_back(iter->second);
       requests_.erase(iter);
@@ skipping 11 matching lines @@
   requests_.clear();
   base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE,
                                                 base::Bind(callback, true));
 }
 
 StoreState RequestQueueInMemoryStore::state() const {
   return StoreState::LOADED;
 }
 
 }  // namespace offline_pages