| 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
|
| deleted file mode 100644
|
| index f46f9a100133ea68d9bd729032b85c0484ffe0c4..0000000000000000000000000000000000000000
|
| --- a/components/offline_pages/background/request_queue_in_memory_store.cc
|
| +++ /dev/null
|
| @@ -1,134 +0,0 @@
|
| -// 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"
|
| -#include "base/threading/thread_task_runner_handle.h"
|
| -#include "components/offline_pages/background/save_page_request.h"
|
| -
|
| -namespace offline_pages {
|
| -
|
| -RequestQueueInMemoryStore::RequestQueueInMemoryStore() {}
|
| -
|
| -RequestQueueInMemoryStore::~RequestQueueInMemoryStore() {}
|
| -
|
| -void RequestQueueInMemoryStore::GetRequests(
|
| - const GetRequestsCallback& callback) {
|
| - std::vector<std::unique_ptr<SavePageRequest>> result_requests;
|
| - for (const auto& id_request_pair : requests_) {
|
| - std::unique_ptr<SavePageRequest> request(
|
| - new SavePageRequest(id_request_pair.second));
|
| - 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()));
|
| -
|
| - 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()) {
|
| - status = ItemActionStatus::SUCCESS;
|
| - result->updated_items.push_back(iter->second);
|
| - } else {
|
| - status = ItemActionStatus::NOT_FOUND;
|
| - }
|
| - result->item_statuses.push_back(std::make_pair(request_id, status));
|
| - }
|
| -
|
| - base::ThreadTaskRunnerHandle::Get()->PostTask(
|
| - FROM_HERE, base::Bind(callback, base::Passed(&result)));
|
| -}
|
| -
|
| -void RequestQueueInMemoryStore::AddRequest(const SavePageRequest& request,
|
| - const AddCallback& callback) {
|
| - RequestsMap::iterator iter = requests_.find(request.request_id());
|
| - ItemActionStatus status;
|
| - if (iter == requests_.end()) {
|
| - requests_.insert(iter, std::make_pair(request.request_id(), request));
|
| - status = ItemActionStatus::SUCCESS;
|
| - } else {
|
| - 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()));
|
| -
|
| - 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));
|
| -
|
| - 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);
|
| - } else {
|
| - status = ItemActionStatus::NOT_FOUND;
|
| - }
|
| - result->item_statuses.push_back(std::make_pair(request_id, status));
|
| - }
|
| -
|
| - base::ThreadTaskRunnerHandle::Get()->PostTask(
|
| - FROM_HERE, base::Bind(callback, base::Passed(&result)));
|
| -}
|
| -
|
| -void RequestQueueInMemoryStore::Reset(const ResetCallback& callback) {
|
| - requests_.clear();
|
| - base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE,
|
| - base::Bind(callback, true));
|
| -}
|
| -
|
| -StoreState RequestQueueInMemoryStore::state() const {
|
| - return StoreState::LOADED;
|
| -}
|
| -
|
| -} // namespace offline_pages
|
|
|