Use SNAPSHOT sync mode for LocalSync

chrome/browser/sync_file_system/local/local_file_sync_service.cc

 // Copyright 2013 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 "chrome/browser/sync_file_system/local/local_file_sync_service.h"
 
 #include "base/stl_util.h"
 #include "chrome/browser/extensions/extension_service.h"
 #include "chrome/browser/extensions/extension_system.h"
 #include "chrome/browser/profiles/profile.h"
 #include "chrome/browser/sync_file_system/file_change.h"
 #include "chrome/browser/sync_file_system/local/local_file_change_tracker.h"
 #include "chrome/browser/sync_file_system/local/local_file_sync_context.h"
 #include "chrome/browser/sync_file_system/local/sync_file_system_backend.h"
 #include "chrome/browser/sync_file_system/local_change_processor.h"
 #include "chrome/browser/sync_file_system/logger.h"
 #include "chrome/browser/sync_file_system/sync_file_metadata.h"
 #include "content/public/browser/browser_context.h"
 #include "content/public/browser/browser_thread.h"
 #include "content/public/browser/site_instance.h"
 #include "content/public/browser/storage_partition.h"
 #include "url/gurl.h"
 #include "webkit/browser/fileapi/file_system_context.h"
 #include "webkit/browser/fileapi/file_system_url.h"
+#include "webkit/common/blob/scoped_file.h"
 
 using content::BrowserThread;
 using fileapi::FileSystemURL;
 
 namespace sync_file_system {
 
 namespace {
 
 void PrepareForProcessRemoteChangeCallbackAdapter(
     const RemoteChangeProcessor::PrepareChangeCallback& callback,
     SyncStatusCode status,
-    const LocalFileSyncInfo& sync_file_info) {
+    const LocalFileSyncInfo& sync_file_info,
+    scoped_ptr<webkit_blob::ScopedFile> snapshot) {
   callback.Run(status, sync_file_info.metadata, sync_file_info.changes);
 }
 
 }  // namespace
 
 LocalFileSyncService::OriginChangeMap::OriginChangeMap()
     : next_(change_count_map_.end()) {}
 LocalFileSyncService::OriginChangeMap::~OriginChangeMap() {}
 
 bool LocalFileSyncService::OriginChangeMap::NextOriginToProcess(GURL* origin) {
@@ skipping 43 matching lines @@
     disabled_origins_.erase(origin);
   else
     disabled_origins_.insert(origin);
 }
 
 // LocalFileSyncService -------------------------------------------------------
 
 LocalFileSyncService::LocalFileSyncService(Profile* profile)
     : profile_(profile),
       sync_context_(new LocalFileSyncContext(
+          profile_->GetPath(),
           BrowserThread::GetMessageLoopProxyForThread(BrowserThread::UI).get(),
           BrowserThread::GetMessageLoopProxyForThread(BrowserThread::IO)
               .get())),
       local_change_processor_(NULL) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   sync_context_->AddOriginChangeObserver(this);
 }
 
 LocalFileSyncService::~LocalFileSyncService() {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
@@ skipping 245 matching lines @@
   DVLOG(1) << "Local sync is finished with: " << status
            << " on " << url.DebugString();
   DCHECK(!local_sync_callback_.is_null());
   SyncFileCallback callback = local_sync_callback_;
   local_sync_callback_.Reset();
   callback.Run(status, url);
 }
 
 void LocalFileSyncService::DidGetFileForLocalSync(
     SyncStatusCode status,
-    const LocalFileSyncInfo& sync_file_info) {
+    const LocalFileSyncInfo& sync_file_info,
+    scoped_ptr<webkit_blob::ScopedFile> snapshot) {
   DCHECK(!local_sync_callback_.is_null());
   if (status != SYNC_STATUS_OK) {
     RunLocalSyncCallback(status, sync_file_info.url);
     return;
   }
   if (sync_file_info.changes.empty()) {
     // There's a slight chance this could happen.
     SyncFileCallback callback = local_sync_callback_;
     local_sync_callback_.Reset();
     ProcessLocalChange(callback);
     return;
   }
 
   FileChange next_change = sync_file_info.changes.front();
   DVLOG(1) << "ProcessLocalChange: " << sync_file_info.url.DebugString()
            << " change:" << next_change.DebugString();
 
   local_change_processor_->ApplyLocalChange(
       next_change,
       sync_file_info.local_file_path,
       sync_file_info.metadata,
       sync_file_info.url,
       base::Bind(&LocalFileSyncService::ProcessNextChangeForURL,
-                 AsWeakPtr(), sync_file_info,
+                 AsWeakPtr(), base::Passed(&snapshot), sync_file_info,
                  next_change, sync_file_info.changes.PopAndGetNewList()));
 }
 
 void LocalFileSyncService::ProcessNextChangeForURL(
+    scoped_ptr<webkit_blob::ScopedFile> snapshot,
     const LocalFileSyncInfo& sync_file_info,
     const FileChange& processed_change,
     const FileChangeList& changes,
     SyncStatusCode status) {
   DVLOG(1) << "Processed one local change: "
            << sync_file_info.url.DebugString()
            << " change:" << processed_change.DebugString()
            << " status:" << status;
 
   if (status == SYNC_STATUS_RETRY) {
     local_change_processor_->ApplyLocalChange(
         processed_change,
         sync_file_info.local_file_path,
         sync_file_info.metadata,
         sync_file_info.url,
         base::Bind(&LocalFileSyncService::ProcessNextChangeForURL,
-                   AsWeakPtr(), sync_file_info, processed_change, changes));
+                   AsWeakPtr(), base::Passed(&snapshot),
+                   sync_file_info, processed_change, changes));
     return;
   }
 
   if (status == SYNC_FILE_ERROR_NOT_FOUND &&
       processed_change.change() == FileChange::FILE_CHANGE_DELETE) {
     // This must be ok (and could happen).
     status = SYNC_STATUS_OK;
   }
 
   const FileSystemURL& url = sync_file_info.url;
   if (status != SYNC_STATUS_OK || changes.empty()) {
     DCHECK(ContainsKey(origin_to_contexts_, url.origin()));
     sync_context_->CommitChangeStatusForURL(
         origin_to_contexts_[url.origin()], url, status,
         base::Bind(&LocalFileSyncService::RunLocalSyncCallback,
                   AsWeakPtr(), status, url));
     return;
   }
 
   FileChange next_change = changes.front();
   local_change_processor_->ApplyLocalChange(
       changes.front(),
       sync_file_info.local_file_path,
       sync_file_info.metadata,
       url,
       base::Bind(&LocalFileSyncService::ProcessNextChangeForURL,
-                 AsWeakPtr(), sync_file_info,
+                 AsWeakPtr(), base::Passed(&snapshot), sync_file_info,
                  next_change, changes.PopAndGetNewList()));
 }
 
 }  // namespace sync_file_system