| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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_file_sync_service.h" | 5 #include "chrome/browser/sync_file_system/drive_file_sync_service.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 #include <string> | 8 #include <string> |
| 9 #include <utility> | 9 #include <utility> |
| 10 | 10 |
| (...skipping 393 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 404 } | 404 } |
| 405 | 405 |
| 406 EnsureOriginRootDirectory( | 406 EnsureOriginRootDirectory( |
| 407 origin, base::Bind(&DriveFileSyncService::DidGetDriveDirectoryForOrigin, | 407 origin, base::Bind(&DriveFileSyncService::DidGetDriveDirectoryForOrigin, |
| 408 AsWeakPtr(), base::Passed(&token), origin, callback)); | 408 AsWeakPtr(), base::Passed(&token), origin, callback)); |
| 409 } | 409 } |
| 410 | 410 |
| 411 void DriveFileSyncService::UnregisterOriginForTrackingChanges( | 411 void DriveFileSyncService::UnregisterOriginForTrackingChanges( |
| 412 const GURL& origin, | 412 const GURL& origin, |
| 413 const SyncStatusCallback& callback) { | 413 const SyncStatusCallback& callback) { |
| 414 scoped_ptr<TaskToken> token(GetToken(FROM_HERE, TASK_TYPE_DATABASE, "")); | 414 scoped_ptr<TaskToken> token( |
| 415 GetToken(FROM_HERE, TASK_TYPE_DATABASE, std::string())); |
| 415 if (!token) { | 416 if (!token) { |
| 416 pending_tasks_.push_back(base::Bind( | 417 pending_tasks_.push_back(base::Bind( |
| 417 &DriveFileSyncService::UnregisterOriginForTrackingChanges, | 418 &DriveFileSyncService::UnregisterOriginForTrackingChanges, |
| 418 AsWeakPtr(), origin, callback)); | 419 AsWeakPtr(), origin, callback)); |
| 419 return; | 420 return; |
| 420 } | 421 } |
| 421 | 422 |
| 422 // TODO(nhiroki): Add helper function to forget remote changes for the given | 423 // TODO(nhiroki): Add helper function to forget remote changes for the given |
| 423 // origin like "ForgetRemoteChangesForOrigin(origin)". | 424 // origin like "ForgetRemoteChangesForOrigin(origin)". |
| 424 // http://crbug.com/211600 | 425 // http://crbug.com/211600 |
| (...skipping 10 matching lines...) Expand all Loading... |
| 435 &DriveFileSyncService::DidChangeOriginOnMetadataStore, | 436 &DriveFileSyncService::DidChangeOriginOnMetadataStore, |
| 436 AsWeakPtr(), base::Passed(&token), callback)); | 437 AsWeakPtr(), base::Passed(&token), callback)); |
| 437 } | 438 } |
| 438 | 439 |
| 439 void DriveFileSyncService::EnableOriginForTrackingChanges( | 440 void DriveFileSyncService::EnableOriginForTrackingChanges( |
| 440 const GURL& origin, | 441 const GURL& origin, |
| 441 const SyncStatusCallback& callback) { | 442 const SyncStatusCallback& callback) { |
| 442 if (!metadata_store_->IsOriginDisabled(origin)) | 443 if (!metadata_store_->IsOriginDisabled(origin)) |
| 443 return; | 444 return; |
| 444 | 445 |
| 445 scoped_ptr<TaskToken> token(GetToken(FROM_HERE, TASK_TYPE_DATABASE, "")); | 446 scoped_ptr<TaskToken> token( |
| 447 GetToken(FROM_HERE, TASK_TYPE_DATABASE, std::string())); |
| 446 if (!token) { | 448 if (!token) { |
| 447 pending_tasks_.push_back(base::Bind( | 449 pending_tasks_.push_back(base::Bind( |
| 448 &DriveFileSyncService::EnableOriginForTrackingChanges, | 450 &DriveFileSyncService::EnableOriginForTrackingChanges, |
| 449 AsWeakPtr(), origin, callback)); | 451 AsWeakPtr(), origin, callback)); |
| 450 return; | 452 return; |
| 451 } | 453 } |
| 452 | 454 |
| 453 metadata_store_->EnableOrigin(origin, base::Bind( | 455 metadata_store_->EnableOrigin(origin, base::Bind( |
| 454 &DriveFileSyncService::DidChangeOriginOnMetadataStore, | 456 &DriveFileSyncService::DidChangeOriginOnMetadataStore, |
| 455 AsWeakPtr(), base::Passed(&token), callback)); | 457 AsWeakPtr(), base::Passed(&token), callback)); |
| 456 pending_batch_sync_origins_.insert(origin); | 458 pending_batch_sync_origins_.insert(origin); |
| 457 } | 459 } |
| 458 | 460 |
| 459 void DriveFileSyncService::DisableOriginForTrackingChanges( | 461 void DriveFileSyncService::DisableOriginForTrackingChanges( |
| 460 const GURL& origin, | 462 const GURL& origin, |
| 461 const SyncStatusCallback& callback) { | 463 const SyncStatusCallback& callback) { |
| 462 if (!metadata_store_->IsBatchSyncOrigin(origin) && | 464 if (!metadata_store_->IsBatchSyncOrigin(origin) && |
| 463 !metadata_store_->IsIncrementalSyncOrigin(origin)) | 465 !metadata_store_->IsIncrementalSyncOrigin(origin)) |
| 464 return; | 466 return; |
| 465 | 467 |
| 466 scoped_ptr<TaskToken> token(GetToken(FROM_HERE, TASK_TYPE_DATABASE, "")); | 468 scoped_ptr<TaskToken> token( |
| 469 GetToken(FROM_HERE, TASK_TYPE_DATABASE, std::string())); |
| 467 if (!token) { | 470 if (!token) { |
| 468 pending_tasks_.push_back(base::Bind( | 471 pending_tasks_.push_back(base::Bind( |
| 469 &DriveFileSyncService::DisableOriginForTrackingChanges, | 472 &DriveFileSyncService::DisableOriginForTrackingChanges, |
| 470 AsWeakPtr(), origin, callback)); | 473 AsWeakPtr(), origin, callback)); |
| 471 return; | 474 return; |
| 472 } | 475 } |
| 473 | 476 |
| 474 // TODO(nhiroki): Add helper function to forget remote changes for the given | 477 // TODO(nhiroki): Add helper function to forget remote changes for the given |
| 475 // origin like "ForgetRemoteChangesForOrigin(origin)". | 478 // origin like "ForgetRemoteChangesForOrigin(origin)". |
| 476 // http://crbug.com/211600 | 479 // http://crbug.com/211600 |
| (...skipping 1999 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2476 pending_batch_sync_origins_.insert(origin); | 2479 pending_batch_sync_origins_.insert(origin); |
| 2477 } | 2480 } |
| 2478 callback.Run(status, resource_id); | 2481 callback.Run(status, resource_id); |
| 2479 } | 2482 } |
| 2480 | 2483 |
| 2481 std::string DriveFileSyncService::sync_root_resource_id() { | 2484 std::string DriveFileSyncService::sync_root_resource_id() { |
| 2482 return metadata_store_->sync_root_directory(); | 2485 return metadata_store_->sync_root_directory(); |
| 2483 } | 2486 } |
| 2484 | 2487 |
| 2485 } // namespace sync_file_system | 2488 } // namespace sync_file_system |
| OLD | NEW |