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

Side by Side Diff: content/browser/background_sync/background_sync_manager.cc

Issue 1945753002: Make Service Worker DB UserData methods accept multiple keys at once (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@iid6encrypt
Patch Set: Rebase Created 4 years, 7 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
« no previous file with comments | « no previous file | content/browser/push_messaging/push_messaging_message_filter.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright 2015 The Chromium Authors. All rights reserved. 1 // Copyright 2015 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 "content/browser/background_sync/background_sync_manager.h" 5 #include "content/browser/background_sync/background_sync_manager.h"
6 6
7 #include <utility> 7 #include <utility>
8 8
9 #include "base/barrier_closure.h" 9 #include "base/barrier_closure.h"
10 #include "base/bind.h" 10 #include "base/bind.h"
(...skipping 557 matching lines...) Expand 10 before | Expand all | Expand 10 after
568 base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE, 568 base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE,
569 base::Bind(callback)); 569 base::Bind(callback));
570 return; 570 return;
571 } 571 }
572 572
573 base::Closure barrier_closure = 573 base::Closure barrier_closure =
574 base::BarrierClosure(user_data.size(), base::Bind(callback)); 574 base::BarrierClosure(user_data.size(), base::Bind(callback));
575 575
576 for (const auto& sw_id_and_regs : user_data) { 576 for (const auto& sw_id_and_regs : user_data) {
577 service_worker_context_->ClearRegistrationUserData( 577 service_worker_context_->ClearRegistrationUserData(
578 sw_id_and_regs.first, kBackgroundSyncUserDataKey, 578 sw_id_and_regs.first, {kBackgroundSyncUserDataKey},
579 base::Bind(&BackgroundSyncManager::DisableAndClearManagerClearedOne, 579 base::Bind(&BackgroundSyncManager::DisableAndClearManagerClearedOne,
580 weak_ptr_factory_.GetWeakPtr(), barrier_closure)); 580 weak_ptr_factory_.GetWeakPtr(), barrier_closure));
581 } 581 }
582 } 582 }
583 583
584 void BackgroundSyncManager::DisableAndClearManagerClearedOne( 584 void BackgroundSyncManager::DisableAndClearManagerClearedOne(
585 const base::Closure& barrier_closure, 585 const base::Closure& barrier_closure,
586 ServiceWorkerStatusCode status) { 586 ServiceWorkerStatusCode status) {
587 DCHECK_CURRENTLY_ON(BrowserThread::IO); 587 DCHECK_CURRENTLY_ON(BrowserThread::IO);
588 588
(...skipping 126 matching lines...) Expand 10 before | Expand all | Expand 10 after
715 715
716 void BackgroundSyncManager::StoreDataInBackend( 716 void BackgroundSyncManager::StoreDataInBackend(
717 int64_t sw_registration_id, 717 int64_t sw_registration_id,
718 const GURL& origin, 718 const GURL& origin,
719 const std::string& backend_key, 719 const std::string& backend_key,
720 const std::string& data, 720 const std::string& data,
721 const ServiceWorkerStorage::StatusCallback& callback) { 721 const ServiceWorkerStorage::StatusCallback& callback) {
722 DCHECK_CURRENTLY_ON(BrowserThread::IO); 722 DCHECK_CURRENTLY_ON(BrowserThread::IO);
723 723
724 service_worker_context_->StoreRegistrationUserData( 724 service_worker_context_->StoreRegistrationUserData(
725 sw_registration_id, origin, backend_key, data, callback); 725 sw_registration_id, origin, {{backend_key, data}}, callback);
726 } 726 }
727 727
728 void BackgroundSyncManager::GetDataFromBackend( 728 void BackgroundSyncManager::GetDataFromBackend(
729 const std::string& backend_key, 729 const std::string& backend_key,
730 const ServiceWorkerStorage::GetUserDataForAllRegistrationsCallback& 730 const ServiceWorkerStorage::GetUserDataForAllRegistrationsCallback&
731 callback) { 731 callback) {
732 DCHECK_CURRENTLY_ON(BrowserThread::IO); 732 DCHECK_CURRENTLY_ON(BrowserThread::IO);
733 733
734 service_worker_context_->GetUserDataForAllRegistrations(backend_key, 734 service_worker_context_->GetUserDataForAllRegistrations(backend_key,
735 callback); 735 callback);
(...skipping 506 matching lines...) Expand 10 before | Expand all | Expand 10 after
1242 BackgroundSyncManager::MakeStatusCompletion(const StatusCallback& callback) { 1242 BackgroundSyncManager::MakeStatusCompletion(const StatusCallback& callback) {
1243 DCHECK_CURRENTLY_ON(BrowserThread::IO); 1243 DCHECK_CURRENTLY_ON(BrowserThread::IO);
1244 1244
1245 return base::Bind( 1245 return base::Bind(
1246 &BackgroundSyncManager::CompleteOperationCallback<StatusCallback, 1246 &BackgroundSyncManager::CompleteOperationCallback<StatusCallback,
1247 BackgroundSyncStatus>, 1247 BackgroundSyncStatus>,
1248 weak_ptr_factory_.GetWeakPtr(), callback); 1248 weak_ptr_factory_.GetWeakPtr(), callback);
1249 } 1249 }
1250 1250
1251 } // namespace content 1251 } // namespace content
OLDNEW
« no previous file with comments | « no previous file | content/browser/push_messaging/push_messaging_message_filter.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698