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 |