[SyncFS] Make ExtensionService usage of SyncWorker asynchronous

chrome/browser/sync_file_system/drive_backend/sync_worker.h

 // Copyright 2014 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.
 
 #ifndef CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_SYNC_WORKER_H_
 #define CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_SYNC_WORKER_H_
 
 #include <set>
 #include <string>
 
@@ skipping 32 matching lines @@
 namespace drive_backend {
 
 class LocalToRemoteSyncer;
 class MetadataDatabase;
 class RemoteToLocalSyncer;
 class SyncEngineContext;
 class SyncEngineInitializer;
 
 class SyncWorker : public SyncTaskManager::Client {
  public:
+  enum AppStatus {
+    APP_STATUS_ENABLED,
+    APP_STATUS_DISABLED,
+    APP_STATUS_UNINSTALLED,
+  };
+
+  typedef base::hash_map<std::string, AppStatus> AppStatusMap;
+
   class Observer {
    public:
     virtual void OnPendingFileListUpdated(int item_count) = 0;
     virtual void OnFileStatusChanged(const fileapi::FileSystemURL& url,
                                      SyncFileStatus file_status,
                                      SyncAction sync_action,
                                      SyncDirection direction) = 0;
     virtual void UpdateServiceState(RemoteServiceState state,
                                     const std::string& description) = 0;
 
    protected:
     virtual ~Observer() {}
   };
 
   static scoped_ptr<SyncWorker> CreateOnWorker(
       const base::FilePath& base_dir,
       Observer* observer,
-      ExtensionServiceInterface* extension_service,
+      const base::WeakPtr<ExtensionServiceInterface>& extension_service,
       scoped_ptr<SyncEngineContext> sync_engine_context,
       leveldb::Env* env_override);
 
   virtual ~SyncWorker();
 
   void Initialize();
 
   // SyncTaskManager::Client overrides
   virtual void MaybeScheduleNextTask() OVERRIDE;
   virtual void NotifyLastOperationStatus(
@@ skipping 42 matching lines @@
   MetadataDatabase* GetMetadataDatabase();
   SyncTaskManager* GetSyncTaskManager();
 
   void AddObserver(Observer* observer);
 
  private:
   friend class DriveBackendSyncTest;
   friend class SyncEngineTest;
 
   SyncWorker(const base::FilePath& base_dir,
-             ExtensionServiceInterface* extension_service,
+             const base::WeakPtr<ExtensionServiceInterface>& extension_service,
              scoped_ptr<SyncEngineContext> sync_engine_context,
              leveldb::Env* env_override);
 
   void DoDisableApp(const std::string& app_id,
                     const SyncStatusCallback& callback);
   void DoEnableApp(const std::string& app_id,
                    const SyncStatusCallback& callback);
 
   void PostInitializeTask();
   void DidInitialize(SyncEngineInitializer* initializer,
                      SyncStatusCode status);
   void UpdateRegisteredApp();
+  void DidQueryAppStatus(const AppStatusMap* app_status);
   void DidProcessRemoteChange(RemoteToLocalSyncer* syncer,
                               const SyncFileCallback& callback,
                               SyncStatusCode status);
   void DidApplyLocalChange(LocalToRemoteSyncer* syncer,
                            const SyncStatusCallback& callback,
                            SyncStatusCode status);
 
   void MaybeStartFetchChanges();
   void DidResolveConflict(SyncStatusCode status);
   void DidFetchChanges(SyncStatusCode status);
@@ skipping 15 matching lines @@
   bool should_check_remote_change_;
   bool listing_remote_changes_;
   base::TimeTicks time_to_check_changes_;
 
   bool sync_enabled_;
   ConflictResolutionPolicy default_conflict_resolution_policy_;
   bool network_available_;
 
   scoped_ptr<SyncTaskManager> task_manager_;
 
-  // TODO(tzik): Add a proxy class for ExtensionServiceInterface to cross
-  // thread, and hold its instance as WeakPtr here.
-  ExtensionServiceInterface* extension_service_;
+  base::WeakPtr<ExtensionServiceInterface> extension_service_;
 
   scoped_ptr<SyncEngineContext> context_;
   ObserverList<Observer> observers_;
 
   base::WeakPtrFactory<SyncWorker> weak_ptr_factory_;
   DISALLOW_COPY_AND_ASSIGN(SyncWorker);
 };
 
 }  // namespace drive_backend
 }  // namespace sync_file_system
 
 #endif  // CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_SYNC_WORKER_H_