Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(272)

Side by Side Diff: components/offline_pages/background/request_queue_in_memory_store.cc

Issue 2379353003: [Offline pages] Applying StoreState to track RequestQueueStore state (Closed)
Patch Set: Addressing feedback Created 4 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright 2016 The Chromium Authors. All rights reserved. 1 // Copyright 2016 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "components/offline_pages/background/request_queue_in_memory_store.h" 5 #include "components/offline_pages/background/request_queue_in_memory_store.h"
6 6
7 #include "base/bind.h" 7 #include "base/bind.h"
8 #include "base/location.h" 8 #include "base/location.h"
9 #include "base/threading/thread_task_runner_handle.h" 9 #include "base/threading/thread_task_runner_handle.h"
10 #include "components/offline_pages/background/save_page_request.h" 10 #include "components/offline_pages/background/save_page_request.h"
(...skipping 29 matching lines...) Expand all
40 } 40 }
41 41
42 base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE, 42 base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE,
43 base::Bind(callback, status)); 43 base::Bind(callback, status));
44 } 44 }
45 45
46 void RequestQueueInMemoryStore::UpdateRequests( 46 void RequestQueueInMemoryStore::UpdateRequests(
47 const std::vector<SavePageRequest>& requests, 47 const std::vector<SavePageRequest>& requests,
48 const UpdateCallback& callback) { 48 const UpdateCallback& callback) {
49 std::unique_ptr<UpdateRequestsResult> result( 49 std::unique_ptr<UpdateRequestsResult> result(
50 new UpdateRequestsResult(StoreState::LOADED)); 50 new UpdateRequestsResult(state()));
51 51
52 ItemActionStatus status; 52 ItemActionStatus status;
53 for (const auto& request : requests) { 53 for (const auto& request : requests) {
54 RequestsMap::iterator iter = requests_.find(request.request_id()); 54 RequestsMap::iterator iter = requests_.find(request.request_id());
55 if (iter != requests_.end()) { 55 if (iter != requests_.end()) {
56 status = ItemActionStatus::SUCCESS; 56 status = ItemActionStatus::SUCCESS;
57 iter->second = request; 57 iter->second = request;
58 result->updated_items.push_back(request); 58 result->updated_items.push_back(request);
59 } else { 59 } else {
60 status = ItemActionStatus::NOT_FOUND; 60 status = ItemActionStatus::NOT_FOUND;
(...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after
124 FROM_HERE, 124 FROM_HERE,
125 base::Bind(callback, results, base::Passed(std::move(requests)))); 125 base::Bind(callback, results, base::Passed(std::move(requests))));
126 } 126 }
127 127
128 void RequestQueueInMemoryStore::Reset(const ResetCallback& callback) { 128 void RequestQueueInMemoryStore::Reset(const ResetCallback& callback) {
129 requests_.clear(); 129 requests_.clear();
130 base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE, 130 base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE,
131 base::Bind(callback, true)); 131 base::Bind(callback, true));
132 } 132 }
133 133
134 StoreState RequestQueueInMemoryStore::state() const {
135 return StoreState::LOADED;
136 }
137
134 } // namespace offline_pages 138 } // namespace offline_pages
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698