OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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 #include "chrome/browser/sync_file_system/drive_backend/sync_engine_initializer.
h" | 5 #include "chrome/browser/sync_file_system/drive_backend/sync_engine_initializer.
h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/callback.h" | 8 #include "base/callback.h" |
9 #include "base/logging.h" | 9 #include "base/logging.h" |
10 #include "chrome/browser/drive/drive_api_service.h" | 10 #include "chrome/browser/drive/drive_api_service.h" |
11 #include "chrome/browser/drive/drive_api_util.h" | 11 #include "chrome/browser/drive/drive_api_util.h" |
12 #include "chrome/browser/sync_file_system/drive_backend/drive_backend_constants.
h" | 12 #include "chrome/browser/sync_file_system/drive_backend/drive_backend_constants.
h" |
13 #include "chrome/browser/sync_file_system/drive_backend/metadata_database.h" | 13 #include "chrome/browser/sync_file_system/drive_backend/metadata_database.h" |
14 #include "chrome/browser/sync_file_system/drive_backend/sync_engine_context.h" | 14 #include "chrome/browser/sync_file_system/drive_backend/sync_engine_context.h" |
15 #include "chrome/browser/sync_file_system/drive_backend_v1/drive_file_sync_util.
h" | 15 #include "chrome/browser/sync_file_system/drive_backend_v1/drive_file_sync_util.
h" |
| 16 #include "chrome/browser/sync_file_system/logger.h" |
16 #include "google_apis/drive/drive_api_parser.h" | 17 #include "google_apis/drive/drive_api_parser.h" |
17 #include "google_apis/drive/gdata_wapi_parser.h" | 18 #include "google_apis/drive/gdata_wapi_parser.h" |
18 | 19 |
19 namespace sync_file_system { | 20 namespace sync_file_system { |
20 namespace drive_backend { | 21 namespace drive_backend { |
21 | 22 |
22 namespace { | 23 namespace { |
23 | 24 |
24 //////////////////////////////////////////////////////////////////////////////// | 25 //////////////////////////////////////////////////////////////////////////////// |
25 // Functions below are for wrapping the access to legacy GData WAPI classes. | 26 // Functions below are for wrapping the access to legacy GData WAPI classes. |
(...skipping 78 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
104 DCHECK(task_runner); | 105 DCHECK(task_runner); |
105 DCHECK(drive_service_); | 106 DCHECK(drive_service_); |
106 } | 107 } |
107 | 108 |
108 SyncEngineInitializer::~SyncEngineInitializer() { | 109 SyncEngineInitializer::~SyncEngineInitializer() { |
109 if (!cancel_callback_.is_null()) | 110 if (!cancel_callback_.is_null()) |
110 cancel_callback_.Run(); | 111 cancel_callback_.Run(); |
111 } | 112 } |
112 | 113 |
113 void SyncEngineInitializer::Run(const SyncStatusCallback& callback) { | 114 void SyncEngineInitializer::Run(const SyncStatusCallback& callback) { |
| 115 util::Log(logging::LOG_VERBOSE, FROM_HERE, "[Initialize] Start."); |
| 116 |
114 // The metadata seems to have been already initialized. Just return with OK. | 117 // The metadata seems to have been already initialized. Just return with OK. |
115 if (sync_context_ && sync_context_->GetMetadataDatabase()) { | 118 if (sync_context_ && sync_context_->GetMetadataDatabase()) { |
| 119 util::Log(logging::LOG_VERBOSE, FROM_HERE, |
| 120 "[Initialize] Already initialized."); |
116 callback.Run(SYNC_STATUS_OK); | 121 callback.Run(SYNC_STATUS_OK); |
117 return; | 122 return; |
118 } | 123 } |
119 | 124 |
120 MetadataDatabase::Create( | 125 MetadataDatabase::Create( |
121 task_runner_.get(), database_path_, | 126 task_runner_.get(), database_path_, |
122 base::Bind(&SyncEngineInitializer::DidCreateMetadataDatabase, | 127 base::Bind(&SyncEngineInitializer::DidCreateMetadataDatabase, |
123 weak_ptr_factory_.GetWeakPtr(), callback)); | 128 weak_ptr_factory_.GetWeakPtr(), callback)); |
124 } | 129 } |
125 | 130 |
126 scoped_ptr<MetadataDatabase> SyncEngineInitializer::PassMetadataDatabase() { | 131 scoped_ptr<MetadataDatabase> SyncEngineInitializer::PassMetadataDatabase() { |
127 return metadata_database_.Pass(); | 132 return metadata_database_.Pass(); |
128 } | 133 } |
129 | 134 |
130 void SyncEngineInitializer::DidCreateMetadataDatabase( | 135 void SyncEngineInitializer::DidCreateMetadataDatabase( |
131 const SyncStatusCallback& callback, | 136 const SyncStatusCallback& callback, |
132 SyncStatusCode status, | 137 SyncStatusCode status, |
133 scoped_ptr<MetadataDatabase> instance) { | 138 scoped_ptr<MetadataDatabase> instance) { |
134 if (status != SYNC_STATUS_OK) { | 139 if (status != SYNC_STATUS_OK) { |
| 140 util::Log(logging::LOG_VERBOSE, FROM_HERE, |
| 141 "[Initialize] Failed to initialize MetadataDatabase."); |
135 callback.Run(status); | 142 callback.Run(status); |
136 return; | 143 return; |
137 } | 144 } |
138 | 145 |
139 DCHECK(instance); | 146 DCHECK(instance); |
140 metadata_database_ = instance.Pass(); | 147 metadata_database_ = instance.Pass(); |
141 if (metadata_database_->HasSyncRoot()) { | 148 if (metadata_database_->HasSyncRoot()) { |
| 149 util::Log(logging::LOG_VERBOSE, FROM_HERE, |
| 150 "[Initialize] Found Local cache of sync-root."); |
142 callback.Run(SYNC_STATUS_OK); | 151 callback.Run(SYNC_STATUS_OK); |
143 return; | 152 return; |
144 } | 153 } |
145 | 154 |
146 GetAboutResource(callback); | 155 GetAboutResource(callback); |
147 } | 156 } |
148 | 157 |
149 void SyncEngineInitializer::GetAboutResource( | 158 void SyncEngineInitializer::GetAboutResource( |
150 const SyncStatusCallback& callback) { | 159 const SyncStatusCallback& callback) { |
151 set_used_network(true); | 160 set_used_network(true); |
152 drive_service_->GetAboutResource( | 161 drive_service_->GetAboutResource( |
153 base::Bind(&SyncEngineInitializer::DidGetAboutResource, | 162 base::Bind(&SyncEngineInitializer::DidGetAboutResource, |
154 weak_ptr_factory_.GetWeakPtr(), callback)); | 163 weak_ptr_factory_.GetWeakPtr(), callback)); |
155 } | 164 } |
156 | 165 |
157 void SyncEngineInitializer::DidGetAboutResource( | 166 void SyncEngineInitializer::DidGetAboutResource( |
158 const SyncStatusCallback& callback, | 167 const SyncStatusCallback& callback, |
159 google_apis::GDataErrorCode error, | 168 google_apis::GDataErrorCode error, |
160 scoped_ptr<google_apis::AboutResource> about_resource) { | 169 scoped_ptr<google_apis::AboutResource> about_resource) { |
161 cancel_callback_.Reset(); | 170 cancel_callback_.Reset(); |
162 | 171 |
163 SyncStatusCode status = GDataErrorCodeToSyncStatusCode(error); | 172 SyncStatusCode status = GDataErrorCodeToSyncStatusCode(error); |
164 if (status != SYNC_STATUS_OK) { | 173 if (status != SYNC_STATUS_OK) { |
| 174 util::Log(logging::LOG_VERBOSE, FROM_HERE, |
| 175 "[Initialize] Failed to get AboutResource."); |
165 callback.Run(status); | 176 callback.Run(status); |
166 return; | 177 return; |
167 } | 178 } |
168 | 179 |
169 DCHECK(about_resource); | 180 DCHECK(about_resource); |
170 root_folder_id_ = about_resource->root_folder_id(); | 181 root_folder_id_ = about_resource->root_folder_id(); |
171 largest_change_id_ = about_resource->largest_change_id(); | 182 largest_change_id_ = about_resource->largest_change_id(); |
172 | 183 |
173 DCHECK(!root_folder_id_.empty()); | 184 DCHECK(!root_folder_id_.empty()); |
174 FindSyncRoot(callback); | 185 FindSyncRoot(callback); |
175 } | 186 } |
176 | 187 |
177 void SyncEngineInitializer::FindSyncRoot(const SyncStatusCallback& callback) { | 188 void SyncEngineInitializer::FindSyncRoot(const SyncStatusCallback& callback) { |
178 if (find_sync_root_retry_count_++ >= kMaxRetry) { | 189 if (find_sync_root_retry_count_++ >= kMaxRetry) { |
| 190 util::Log(logging::LOG_VERBOSE, FROM_HERE, |
| 191 "[Initialize] Reached max retry count."); |
179 callback.Run(SYNC_STATUS_FAILED); | 192 callback.Run(SYNC_STATUS_FAILED); |
180 return; | 193 return; |
181 } | 194 } |
182 | 195 |
183 set_used_network(true); | 196 set_used_network(true); |
184 cancel_callback_ = drive_service_->SearchByTitle( | 197 cancel_callback_ = drive_service_->SearchByTitle( |
185 kSyncRootFolderTitle, | 198 kSyncRootFolderTitle, |
186 std::string(), // parent_folder_id | 199 std::string(), // parent_folder_id |
187 base::Bind(&SyncEngineInitializer::DidFindSyncRoot, | 200 base::Bind(&SyncEngineInitializer::DidFindSyncRoot, |
188 weak_ptr_factory_.GetWeakPtr(), | 201 weak_ptr_factory_.GetWeakPtr(), |
189 callback)); | 202 callback)); |
190 } | 203 } |
191 | 204 |
192 void SyncEngineInitializer::DidFindSyncRoot( | 205 void SyncEngineInitializer::DidFindSyncRoot( |
193 const SyncStatusCallback& callback, | 206 const SyncStatusCallback& callback, |
194 google_apis::GDataErrorCode error, | 207 google_apis::GDataErrorCode error, |
195 scoped_ptr<google_apis::ResourceList> resource_list) { | 208 scoped_ptr<google_apis::ResourceList> resource_list) { |
196 cancel_callback_.Reset(); | 209 cancel_callback_.Reset(); |
197 | 210 |
198 SyncStatusCode status = GDataErrorCodeToSyncStatusCode(error); | 211 SyncStatusCode status = GDataErrorCodeToSyncStatusCode(error); |
199 if (status != SYNC_STATUS_OK) { | 212 if (status != SYNC_STATUS_OK) { |
| 213 util::Log(logging::LOG_VERBOSE, FROM_HERE, |
| 214 "[Initialize] Failed to find sync root."); |
200 callback.Run(status); | 215 callback.Run(status); |
201 return; | 216 return; |
202 } | 217 } |
203 | 218 |
| 219 if (!resource_list) { |
| 220 NOTREACHED(); |
| 221 util::Log(logging::LOG_VERBOSE, FROM_HERE, |
| 222 "[Initialize] Got invalid resource list."); |
| 223 callback.Run(SYNC_STATUS_FAILED); |
| 224 return; |
| 225 } |
| 226 |
204 ScopedVector<google_apis::ResourceEntry>* entries = | 227 ScopedVector<google_apis::ResourceEntry>* entries = |
205 resource_list->mutable_entries(); | 228 resource_list->mutable_entries(); |
206 for (ScopedVector<google_apis::ResourceEntry>::iterator itr = | 229 for (ScopedVector<google_apis::ResourceEntry>::iterator itr = |
207 entries->begin(); | 230 entries->begin(); |
208 itr != entries->end(); ++itr) { | 231 itr != entries->end(); ++itr) { |
209 google_apis::ResourceEntry* entry = *itr; | 232 google_apis::ResourceEntry* entry = *itr; |
210 | 233 |
211 // Ignore deleted folder. | 234 // Ignore deleted folder. |
212 if (IsDeleted(*entry)) | 235 if (IsDeleted(*entry)) |
213 continue; | 236 continue; |
(...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
259 | 282 |
260 void SyncEngineInitializer::DidCreateSyncRoot( | 283 void SyncEngineInitializer::DidCreateSyncRoot( |
261 const SyncStatusCallback& callback, | 284 const SyncStatusCallback& callback, |
262 google_apis::GDataErrorCode error, | 285 google_apis::GDataErrorCode error, |
263 scoped_ptr<google_apis::ResourceEntry> entry) { | 286 scoped_ptr<google_apis::ResourceEntry> entry) { |
264 DCHECK(!sync_root_folder_); | 287 DCHECK(!sync_root_folder_); |
265 cancel_callback_.Reset(); | 288 cancel_callback_.Reset(); |
266 | 289 |
267 SyncStatusCode status = GDataErrorCodeToSyncStatusCode(error); | 290 SyncStatusCode status = GDataErrorCodeToSyncStatusCode(error); |
268 if (status != SYNC_STATUS_OK) { | 291 if (status != SYNC_STATUS_OK) { |
| 292 util::Log(logging::LOG_VERBOSE, FROM_HERE, |
| 293 "[Initialize] Failed to create sync root."); |
269 callback.Run(status); | 294 callback.Run(status); |
270 return; | 295 return; |
271 } | 296 } |
272 | 297 |
273 FindSyncRoot(callback); | 298 FindSyncRoot(callback); |
274 } | 299 } |
275 | 300 |
276 void SyncEngineInitializer::DetachSyncRoot(const SyncStatusCallback& callback) { | 301 void SyncEngineInitializer::DetachSyncRoot(const SyncStatusCallback& callback) { |
277 DCHECK(sync_root_folder_); | 302 DCHECK(sync_root_folder_); |
278 set_used_network(true); | 303 set_used_network(true); |
279 cancel_callback_ = drive_service_->RemoveResourceFromDirectory( | 304 cancel_callback_ = drive_service_->RemoveResourceFromDirectory( |
280 root_folder_id_, GetID(*sync_root_folder_), | 305 root_folder_id_, GetID(*sync_root_folder_), |
281 base::Bind(&SyncEngineInitializer::DidDetachSyncRoot, | 306 base::Bind(&SyncEngineInitializer::DidDetachSyncRoot, |
282 weak_ptr_factory_.GetWeakPtr(), | 307 weak_ptr_factory_.GetWeakPtr(), |
283 callback)); | 308 callback)); |
284 } | 309 } |
285 | 310 |
286 void SyncEngineInitializer::DidDetachSyncRoot( | 311 void SyncEngineInitializer::DidDetachSyncRoot( |
287 const SyncStatusCallback& callback, | 312 const SyncStatusCallback& callback, |
288 google_apis::GDataErrorCode error) { | 313 google_apis::GDataErrorCode error) { |
289 cancel_callback_.Reset(); | 314 cancel_callback_.Reset(); |
290 | 315 |
291 SyncStatusCode status = GDataErrorCodeToSyncStatusCode(error); | 316 SyncStatusCode status = GDataErrorCodeToSyncStatusCode(error); |
292 if (status != SYNC_STATUS_OK) { | 317 if (status != SYNC_STATUS_OK) { |
| 318 util::Log(logging::LOG_VERBOSE, FROM_HERE, |
| 319 "[Initialize] Failed to detach sync root."); |
293 callback.Run(status); | 320 callback.Run(status); |
294 return; | 321 return; |
295 } | 322 } |
296 | 323 |
297 ListAppRootFolders(callback); | 324 ListAppRootFolders(callback); |
298 } | 325 } |
299 | 326 |
300 void SyncEngineInitializer::ListAppRootFolders( | 327 void SyncEngineInitializer::ListAppRootFolders( |
301 const SyncStatusCallback& callback) { | 328 const SyncStatusCallback& callback) { |
302 DCHECK(sync_root_folder_); | 329 DCHECK(sync_root_folder_); |
303 set_used_network(true); | 330 set_used_network(true); |
304 cancel_callback_ = drive_service_->GetResourceListInDirectory( | 331 cancel_callback_ = drive_service_->GetResourceListInDirectory( |
305 GetID(*sync_root_folder_), | 332 GetID(*sync_root_folder_), |
306 base::Bind(&SyncEngineInitializer::DidListAppRootFolders, | 333 base::Bind(&SyncEngineInitializer::DidListAppRootFolders, |
307 weak_ptr_factory_.GetWeakPtr(), | 334 weak_ptr_factory_.GetWeakPtr(), |
308 callback)); | 335 callback)); |
309 } | 336 } |
310 | 337 |
311 void SyncEngineInitializer::DidListAppRootFolders( | 338 void SyncEngineInitializer::DidListAppRootFolders( |
312 const SyncStatusCallback& callback, | 339 const SyncStatusCallback& callback, |
313 google_apis::GDataErrorCode error, | 340 google_apis::GDataErrorCode error, |
314 scoped_ptr<google_apis::ResourceList> resource_list) { | 341 scoped_ptr<google_apis::ResourceList> resource_list) { |
315 cancel_callback_.Reset(); | 342 cancel_callback_.Reset(); |
316 | 343 |
317 SyncStatusCode status = GDataErrorCodeToSyncStatusCode(error); | 344 SyncStatusCode status = GDataErrorCodeToSyncStatusCode(error); |
318 if (status != SYNC_STATUS_OK) { | 345 if (status != SYNC_STATUS_OK) { |
| 346 util::Log(logging::LOG_VERBOSE, FROM_HERE, |
| 347 "[Initialize] Failed to get initial app-root folders."); |
319 callback.Run(status); | 348 callback.Run(status); |
320 return; | 349 return; |
321 } | 350 } |
322 | 351 |
| 352 if (!resource_list) { |
| 353 NOTREACHED(); |
| 354 util::Log(logging::LOG_VERBOSE, FROM_HERE, |
| 355 "[Initialize] Got invalid initial app-root list."); |
| 356 callback.Run(SYNC_STATUS_FAILED); |
| 357 return; |
| 358 } |
| 359 |
323 ScopedVector<google_apis::ResourceEntry>* new_entries = | 360 ScopedVector<google_apis::ResourceEntry>* new_entries = |
324 resource_list->mutable_entries(); | 361 resource_list->mutable_entries(); |
325 app_root_folders_.insert(app_root_folders_.end(), | 362 app_root_folders_.insert(app_root_folders_.end(), |
326 new_entries->begin(), new_entries->end()); | 363 new_entries->begin(), new_entries->end()); |
327 new_entries->weak_clear(); | 364 new_entries->weak_clear(); |
328 | 365 |
329 set_used_network(true); | 366 set_used_network(true); |
330 if (GetRemainingFileList( | 367 if (GetRemainingFileList( |
331 &cancel_callback_, | 368 &cancel_callback_, |
332 drive_service_, | 369 drive_service_, |
(...skipping 15 matching lines...) Expand all Loading... |
348 ConvertResourceEntriesToFileResources(app_root_folders_), | 385 ConvertResourceEntriesToFileResources(app_root_folders_), |
349 base::Bind(&SyncEngineInitializer::DidPopulateDatabase, | 386 base::Bind(&SyncEngineInitializer::DidPopulateDatabase, |
350 weak_ptr_factory_.GetWeakPtr(), | 387 weak_ptr_factory_.GetWeakPtr(), |
351 callback)); | 388 callback)); |
352 } | 389 } |
353 | 390 |
354 void SyncEngineInitializer::DidPopulateDatabase( | 391 void SyncEngineInitializer::DidPopulateDatabase( |
355 const SyncStatusCallback& callback, | 392 const SyncStatusCallback& callback, |
356 SyncStatusCode status) { | 393 SyncStatusCode status) { |
357 if (status != SYNC_STATUS_OK) { | 394 if (status != SYNC_STATUS_OK) { |
| 395 util::Log(logging::LOG_VERBOSE, FROM_HERE, |
| 396 "[Initialize] Failed to populate initial data" |
| 397 " to MetadataDatabase."); |
358 callback.Run(status); | 398 callback.Run(status); |
359 return; | 399 return; |
360 } | 400 } |
361 | 401 |
| 402 util::Log(logging::LOG_VERBOSE, FROM_HERE, |
| 403 "[Initialize] Completed successfully."); |
362 callback.Run(SYNC_STATUS_OK); | 404 callback.Run(SYNC_STATUS_OK); |
363 } | 405 } |
364 | 406 |
365 } // namespace drive_backend | 407 } // namespace drive_backend |
366 } // namespace sync_file_system | 408 } // namespace sync_file_system |
OLD | NEW |