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 |