SyncFS: Introduce SyncFileSystemBackend

chrome/browser/sync_file_system/local_file_sync_service.cc

 // Copyright (c) 2012 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_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/local_change_processor.h"
 #include "chrome/browser/sync_file_system/logger.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/browser/fileapi/syncable/file_change.h"
 #include "webkit/browser/fileapi/syncable/local_file_change_tracker.h"
 #include "webkit/browser/fileapi/syncable/local_file_sync_context.h"
 #include "webkit/browser/fileapi/syncable/sync_file_metadata.h"
+#include "webkit/browser/fileapi/syncable/sync_file_system_backend.h"
 
 using content::BrowserThread;
 using fileapi::FileSystemURL;
 
 namespace sync_file_system {
 
 namespace {
 
 void PrepareForProcessRemoteChangeCallbackAdapter(
     const RemoteChangeProcessor::PrepareChangeCallback& callback,
@@ skipping 242 matching lines @@
       // This could happen if this is called for apps/origins that haven't
       // been initialized yet, or for apps/origins that are disabled.
       // (Local change tracker could call this for uninitialized origins
       // while it's reading dirty files from the database in the
       // initialization phase.)
       pending_origins_with_changes_.insert(origin);
       continue;
     }
     need_notification = true;
     fileapi::FileSystemContext* context = origin_to_contexts_[origin];
-    DCHECK(context->change_tracker());
+    SyncFileSystemBackend* backend = SyncFileSystemBackend::GetBackend(context);
+    DCHECK(backend);
+    DCHECK(backend->change_tracker());
     origin_change_map_.SetOriginChangeCount(
-        origin, context->change_tracker()->num_changes());
+        origin, backend->change_tracker()->num_changes());
   }
   if (!need_notification)
     return;
   int64 num_changes = origin_change_map_.GetTotalChangeCount();
   FOR_EACH_OBSERVER(Observer, change_observers_,
                     OnLocalChangeAvailable(num_changes));
 }
 
 void LocalFileSyncService::SetOriginEnabled(const GURL& origin, bool enabled) {
   if (!ContainsKey(origin_to_contexts_, origin))
@@ skipping 10 matching lines @@
     callback.Run(status);
     return;
   }
   DCHECK(file_system_context);
   origin_to_contexts_[app_origin] = file_system_context;
 
   if (pending_origins_with_changes_.find(app_origin) !=
       pending_origins_with_changes_.end()) {
     // We have remaining changes for the origin.
     pending_origins_with_changes_.erase(app_origin);
-    DCHECK(file_system_context->change_tracker());
+    SyncFileSystemBackend* backend =
+        SyncFileSystemBackend::GetBackend(file_system_context);
+    DCHECK(backend);
+    DCHECK(backend->change_tracker());
     origin_change_map_.SetOriginChangeCount(
-        app_origin, file_system_context->change_tracker()->num_changes());
+        app_origin, backend->change_tracker()->num_changes());
     int64 num_changes = origin_change_map_.GetTotalChangeCount();
     FOR_EACH_OBSERVER(Observer, change_observers_,
                       OnLocalChangeAvailable(num_changes));
   }
   callback.Run(status);
 }
 
 void LocalFileSyncService::DidInitializeForRemoteSync(
     const FileSystemURL& url,
     fileapi::FileSystemContext* file_system_context,
@@ skipping 92 matching lines @@
       changes.front(),
       sync_file_info.local_file_path,
       sync_file_info.metadata,
       url,
       base::Bind(&LocalFileSyncService::ProcessNextChangeForURL,
                  AsWeakPtr(), sync_file_info,
                  changes.front(), changes.PopAndGetNewList()));
 }
 
 }  // namespace sync_file_system