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

Side by Side Diff: chrome/browser/sync_file_system/drive_backend/sync_worker.cc

Issue 407073003: [SyncFS] Add completion callback to PromoteDemotedChanges (1/3) (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 6 years, 5 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 | Annotate | Revision Log
OLDNEW
1 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 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 "chrome/browser/sync_file_system/drive_backend/sync_worker.h" 5 #include "chrome/browser/sync_file_system/drive_backend/sync_worker.h"
6 6
7 #include <vector> 7 #include <vector>
8 8
9 #include "base/bind.h" 9 #include "base/bind.h"
10 #include "chrome/browser/drive/drive_service_interface.h" 10 #include "chrome/browser/drive/drive_service_interface.h"
(...skipping 216 matching lines...) Expand 10 before | Expand all | Expand 10 after
227 return; 227 return;
228 228
229 FOR_EACH_OBSERVER( 229 FOR_EACH_OBSERVER(
230 Observer, 230 Observer,
231 observers_, 231 observers_,
232 UpdateServiceState( 232 UpdateServiceState(
233 GetCurrentState(), 233 GetCurrentState(),
234 enabled ? "Sync is enabled" : "Sync is disabled")); 234 enabled ? "Sync is enabled" : "Sync is disabled"));
235 } 235 }
236 236
237 void SyncWorker::PromoteDemotedChanges() { 237 void SyncWorker::PromoteDemotedChanges(const base::Closure& callback) {
238 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 238 DCHECK(sequence_checker_.CalledOnValidSequencedThread());
239 239
240 MetadataDatabase* metadata_db = GetMetadataDatabase(); 240 MetadataDatabase* metadata_db = GetMetadataDatabase();
241 if (metadata_db && metadata_db->HasLowPriorityDirtyTracker()) { 241 if (metadata_db && metadata_db->HasLowPriorityDirtyTracker()) {
242 metadata_db->PromoteLowerPriorityTrackersToNormal(); 242 metadata_db->PromoteLowerPriorityTrackersToNormal();
243 FOR_EACH_OBSERVER( 243 FOR_EACH_OBSERVER(
244 Observer, 244 Observer,
245 observers_, 245 observers_,
246 OnPendingFileListUpdated(metadata_db->CountDirtyTracker())); 246 OnPendingFileListUpdated(metadata_db->CountDirtyTracker()));
247 } 247 }
248 callback.Run();
248 } 249 }
249 250
250 void SyncWorker::ApplyLocalChange( 251 void SyncWorker::ApplyLocalChange(
251 const FileChange& local_change, 252 const FileChange& local_change,
252 const base::FilePath& local_path, 253 const base::FilePath& local_path,
253 const SyncFileMetadata& local_metadata, 254 const SyncFileMetadata& local_metadata,
254 const fileapi::FileSystemURL& url, 255 const fileapi::FileSystemURL& url,
255 const SyncStatusCallback& callback) { 256 const SyncStatusCallback& callback) {
256 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 257 DCHECK(sequence_checker_.CalledOnValidSequencedThread());
257 258
(...skipping 480 matching lines...) Expand 10 before | Expand all | Expand 10 after
738 return context_->GetDriveUploader(); 739 return context_->GetDriveUploader();
739 } 740 }
740 741
741 MetadataDatabase* SyncWorker::GetMetadataDatabase() { 742 MetadataDatabase* SyncWorker::GetMetadataDatabase() {
742 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 743 DCHECK(sequence_checker_.CalledOnValidSequencedThread());
743 return context_->GetMetadataDatabase(); 744 return context_->GetMetadataDatabase();
744 } 745 }
745 746
746 } // namespace drive_backend 747 } // namespace drive_backend
747 } // namespace sync_file_system 748 } // namespace sync_file_system
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698