| OLD | NEW |
| 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 #ifndef CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_SYNC_WORKER_H_ | 5 #ifndef CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_SYNC_WORKER_H_ |
| 6 #define CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_SYNC_WORKER_H_ | 6 #define CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_SYNC_WORKER_H_ |
| 7 | 7 |
| 8 #include <set> | 8 #include <set> |
| 9 #include <string> | 9 #include <string> |
| 10 | 10 |
| (...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 66 SyncFileStatus file_status, | 66 SyncFileStatus file_status, |
| 67 SyncAction sync_action, | 67 SyncAction sync_action, |
| 68 SyncDirection direction) = 0; | 68 SyncDirection direction) = 0; |
| 69 virtual void UpdateServiceState(RemoteServiceState state, | 69 virtual void UpdateServiceState(RemoteServiceState state, |
| 70 const std::string& description) = 0; | 70 const std::string& description) = 0; |
| 71 | 71 |
| 72 protected: | 72 protected: |
| 73 virtual ~Observer() {} | 73 virtual ~Observer() {} |
| 74 }; | 74 }; |
| 75 | 75 |
| 76 static scoped_ptr<SyncWorker> CreateOnWorker( | 76 SyncWorker(const base::FilePath& base_dir, |
| 77 const base::FilePath& base_dir, | 77 const base::WeakPtr<ExtensionServiceInterface>& extension_service, |
| 78 Observer* observer, | 78 scoped_ptr<SyncEngineContext> sync_engine_context, |
| 79 const base::WeakPtr<ExtensionServiceInterface>& extension_service, | 79 leveldb::Env* env_override); |
| 80 scoped_ptr<SyncEngineContext> sync_engine_context, | |
| 81 leveldb::Env* env_override); | |
| 82 | 80 |
| 83 virtual ~SyncWorker(); | 81 virtual ~SyncWorker(); |
| 84 | 82 |
| 85 void Initialize(); | 83 void Initialize(); |
| 86 | 84 |
| 87 // SyncTaskManager::Client overrides | 85 // SyncTaskManager::Client overrides |
| 88 virtual void MaybeScheduleNextTask() OVERRIDE; | 86 virtual void MaybeScheduleNextTask() OVERRIDE; |
| 89 virtual void NotifyLastOperationStatus( | 87 virtual void NotifyLastOperationStatus( |
| 90 SyncStatusCode sync_status, bool used_network) OVERRIDE; | 88 SyncStatusCode sync_status, bool used_network) OVERRIDE; |
| 91 | 89 |
| (...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 133 drive::DriveUploaderInterface* GetDriveUploader(); | 131 drive::DriveUploaderInterface* GetDriveUploader(); |
| 134 MetadataDatabase* GetMetadataDatabase(); | 132 MetadataDatabase* GetMetadataDatabase(); |
| 135 SyncTaskManager* GetSyncTaskManager(); | 133 SyncTaskManager* GetSyncTaskManager(); |
| 136 | 134 |
| 137 void AddObserver(Observer* observer); | 135 void AddObserver(Observer* observer); |
| 138 | 136 |
| 139 private: | 137 private: |
| 140 friend class DriveBackendSyncTest; | 138 friend class DriveBackendSyncTest; |
| 141 friend class SyncEngineTest; | 139 friend class SyncEngineTest; |
| 142 | 140 |
| 143 SyncWorker(const base::FilePath& base_dir, | |
| 144 const base::WeakPtr<ExtensionServiceInterface>& extension_service, | |
| 145 scoped_ptr<SyncEngineContext> sync_engine_context, | |
| 146 leveldb::Env* env_override); | |
| 147 | |
| 148 void DoDisableApp(const std::string& app_id, | 141 void DoDisableApp(const std::string& app_id, |
| 149 const SyncStatusCallback& callback); | 142 const SyncStatusCallback& callback); |
| 150 void DoEnableApp(const std::string& app_id, | 143 void DoEnableApp(const std::string& app_id, |
| 151 const SyncStatusCallback& callback); | 144 const SyncStatusCallback& callback); |
| 152 | 145 |
| 153 void PostInitializeTask(); | 146 void PostInitializeTask(); |
| 154 void DidInitialize(SyncEngineInitializer* initializer, | 147 void DidInitialize(SyncEngineInitializer* initializer, |
| 155 SyncStatusCode status); | 148 SyncStatusCode status); |
| 156 void UpdateRegisteredApp(); | 149 void UpdateRegisteredApp(); |
| 157 void DidQueryAppStatus(const AppStatusMap* app_status); | 150 void DidQueryAppStatus(const AppStatusMap* app_status); |
| (...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 196 ObserverList<Observer> observers_; | 189 ObserverList<Observer> observers_; |
| 197 | 190 |
| 198 base::WeakPtrFactory<SyncWorker> weak_ptr_factory_; | 191 base::WeakPtrFactory<SyncWorker> weak_ptr_factory_; |
| 199 DISALLOW_COPY_AND_ASSIGN(SyncWorker); | 192 DISALLOW_COPY_AND_ASSIGN(SyncWorker); |
| 200 }; | 193 }; |
| 201 | 194 |
| 202 } // namespace drive_backend | 195 } // namespace drive_backend |
| 203 } // namespace sync_file_system | 196 } // namespace sync_file_system |
| 204 | 197 |
| 205 #endif // CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_SYNC_WORKER_H_ | 198 #endif // CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_SYNC_WORKER_H_ |
| OLD | NEW |