| 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 122 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 133 drive::DriveServiceInterface* GetDriveService(); | 133 drive::DriveServiceInterface* GetDriveService(); |
| 134 drive::DriveUploaderInterface* GetDriveUploader(); | 134 drive::DriveUploaderInterface* GetDriveUploader(); |
| 135 MetadataDatabase* GetMetadataDatabase(); | 135 MetadataDatabase* GetMetadataDatabase(); |
| 136 SyncTaskManager* GetSyncTaskManager(); | 136 SyncTaskManager* GetSyncTaskManager(); |
| 137 | 137 |
| 138 void AddObserver(Observer* observer); | 138 void AddObserver(Observer* observer); |
| 139 | 139 |
| 140 void DetachFromSequence(); | 140 void DetachFromSequence(); |
| 141 | 141 |
| 142 private: | 142 private: |
| 143 friend class SyncEngineTest; | 143 friend class SyncWorkerTest; |
| 144 | 144 |
| 145 void DoDisableApp(const std::string& app_id, | 145 void DoDisableApp(const std::string& app_id, |
| 146 const SyncStatusCallback& callback); | 146 const SyncStatusCallback& callback); |
| 147 void DoEnableApp(const std::string& app_id, | 147 void DoEnableApp(const std::string& app_id, |
| 148 const SyncStatusCallback& callback); | 148 const SyncStatusCallback& callback); |
| 149 | 149 |
| 150 void PostInitializeTask(); | 150 void PostInitializeTask(); |
| 151 void DidInitialize(SyncEngineInitializer* initializer, | 151 void DidInitialize(SyncEngineInitializer* initializer, |
| 152 SyncStatusCode status); | 152 SyncStatusCode status); |
| 153 void UpdateRegisteredApp(); | 153 void UpdateRegisteredApps(); |
| 154 void DidQueryAppStatus(const AppStatusMap* app_status); | 154 void DidQueryAppStatus(const AppStatusMap* app_status); |
| 155 void DidProcessRemoteChange(RemoteToLocalSyncer* syncer, | 155 void DidProcessRemoteChange(RemoteToLocalSyncer* syncer, |
| 156 const SyncFileCallback& callback, | 156 const SyncFileCallback& callback, |
| 157 SyncStatusCode status); | 157 SyncStatusCode status); |
| 158 void DidApplyLocalChange(LocalToRemoteSyncer* syncer, | 158 void DidApplyLocalChange(LocalToRemoteSyncer* syncer, |
| 159 const SyncStatusCallback& callback, | 159 const SyncStatusCallback& callback, |
| 160 SyncStatusCode status); | 160 SyncStatusCode status); |
| 161 | 161 |
| 162 void MaybeStartFetchChanges(); | 162 void MaybeStartFetchChanges(); |
| 163 void DidResolveConflict(SyncStatusCode status); | 163 void DidResolveConflict(SyncStatusCode status); |
| 164 void DidFetchChanges(SyncStatusCode status); | 164 void DidFetchChanges(SyncStatusCode status); |
| 165 | 165 |
| 166 void UpdateServiceStateFromSyncStatusCode(SyncStatusCode state, | 166 void UpdateServiceStateFromSyncStatusCode(SyncStatusCode state, |
| 167 bool used_network); | 167 bool used_network); |
| 168 void UpdateServiceState(RemoteServiceState state, | 168 void UpdateServiceState(RemoteServiceState state, |
| 169 const std::string& description); | 169 const std::string& description); |
| 170 void UpdateRegisteredApps(); | |
| 171 | 170 |
| 172 base::FilePath base_dir_; | 171 base::FilePath base_dir_; |
| 173 | 172 |
| 174 leveldb::Env* env_override_; | 173 leveldb::Env* env_override_; |
| 175 | 174 |
| 176 // Sync with SyncEngine. | 175 // Sync with SyncEngine. |
| 177 RemoteServiceState service_state_; | 176 RemoteServiceState service_state_; |
| 178 | 177 |
| 179 bool should_check_conflict_; | 178 bool should_check_conflict_; |
| 180 bool should_check_remote_change_; | 179 bool should_check_remote_change_; |
| (...skipping 16 matching lines...) Expand all Loading... |
| 197 base::SequenceChecker sequence_checker_; | 196 base::SequenceChecker sequence_checker_; |
| 198 | 197 |
| 199 base::WeakPtrFactory<SyncWorker> weak_ptr_factory_; | 198 base::WeakPtrFactory<SyncWorker> weak_ptr_factory_; |
| 200 DISALLOW_COPY_AND_ASSIGN(SyncWorker); | 199 DISALLOW_COPY_AND_ASSIGN(SyncWorker); |
| 201 }; | 200 }; |
| 202 | 201 |
| 203 } // namespace drive_backend | 202 } // namespace drive_backend |
| 204 } // namespace sync_file_system | 203 } // namespace sync_file_system |
| 205 | 204 |
| 206 #endif // CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_SYNC_WORKER_H_ | 205 #endif // CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_SYNC_WORKER_H_ |
| OLD | NEW |