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

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

Issue 2053163002: [Offline pages] Adding persistent request queue based on SQLite (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Fixing code comments Created 4 years, 6 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.h" 5 #include "components/offline_pages/background/request_queue.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/request_queue_store.h" 10 #include "components/offline_pages/background/request_queue_store.h"
(...skipping 14 matching lines...) Expand all
25 // Also this may be turned into a method on the request queue or add a policy 25 // Also this may be turned into a method on the request queue or add a policy
26 // parameter in the process. 26 // parameter in the process.
27 callback.Run(result, requests); 27 callback.Run(result, requests);
28 } 28 }
29 29
30 // Completes the add request call. 30 // Completes the add request call.
31 void AddRequestDone(const RequestQueue::AddRequestCallback& callback, 31 void AddRequestDone(const RequestQueue::AddRequestCallback& callback,
32 const SavePageRequest& request, 32 const SavePageRequest& request,
33 RequestQueueStore::UpdateStatus status) { 33 RequestQueueStore::UpdateStatus status) {
34 RequestQueue::AddRequestResult result = 34 RequestQueue::AddRequestResult result =
35 (status == RequestQueueStore::UpdateStatus::ADDED) 35 (status == RequestQueueStore::UpdateStatus::UPDATED)
36 ? RequestQueue::AddRequestResult::SUCCESS 36 ? RequestQueue::AddRequestResult::SUCCESS
37 : RequestQueue::AddRequestResult::STORE_FAILURE; 37 : RequestQueue::AddRequestResult::STORE_FAILURE;
38 callback.Run(result, request); 38 callback.Run(result, request);
39 } 39 }
40 40
41 // Completes the remove request call. 41 // Completes the remove request call.
42 void RemoveRequestDone(const RequestQueue::UpdateRequestCallback& callback, 42 void RemoveRequestDone(const RequestQueue::UpdateRequestCallback& callback,
43 bool success, 43 bool success,
44 int deleted_requests_count) { 44 int deleted_requests_count) {
45 DCHECK_EQ(1, deleted_requests_count); 45 DCHECK_EQ(1, deleted_requests_count);
(...skipping 26 matching lines...) Expand all
72 72
73 void RequestQueue::RemoveRequest(int64_t request_id, 73 void RequestQueue::RemoveRequest(int64_t request_id,
74 const UpdateRequestCallback& callback) { 74 const UpdateRequestCallback& callback) {
75 std::vector<int64_t> request_ids{request_id}; 75 std::vector<int64_t> request_ids{request_id};
76 store_->RemoveRequests(request_ids, base::Bind(RemoveRequestDone, callback)); 76 store_->RemoveRequests(request_ids, base::Bind(RemoveRequestDone, callback));
77 } 77 }
78 78
79 void RequestQueue::PurgeRequests(const PurgeRequestsCallback& callback) {} 79 void RequestQueue::PurgeRequests(const PurgeRequestsCallback& callback) {}
80 80
81 } // namespace offline_pages 81 } // namespace offline_pages
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698