| 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.h" | 5 #include "chrome/browser/sync_file_system/drive_backend/sync_engine.h" |
| 6 | 6 |
| 7 #include <vector> | 7 #include <vector> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/metrics/histogram.h" | 10 #include "base/metrics/histogram.h" |
| (...skipping 106 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 117 | 117 |
| 118 private: | 118 private: |
| 119 scoped_refptr<base::SequencedTaskRunner> ui_task_runner_; | 119 scoped_refptr<base::SequencedTaskRunner> ui_task_runner_; |
| 120 base::WeakPtr<SyncEngine> sync_engine_; | 120 base::WeakPtr<SyncEngine> sync_engine_; |
| 121 | 121 |
| 122 DISALLOW_COPY_AND_ASSIGN(WorkerObserver); | 122 DISALLOW_COPY_AND_ASSIGN(WorkerObserver); |
| 123 }; | 123 }; |
| 124 | 124 |
| 125 namespace { | 125 namespace { |
| 126 | 126 |
| 127 void EmptyStatusCallback(SyncStatusCode status) {} | |
| 128 | |
| 129 void DidRegisterOrigin(const base::TimeTicks& start_time, | 127 void DidRegisterOrigin(const base::TimeTicks& start_time, |
| 130 const SyncStatusCallback& callback, | 128 const SyncStatusCallback& callback, |
| 131 SyncStatusCode status) { | 129 SyncStatusCode status) { |
| 132 base::TimeDelta delta(base::TimeTicks::Now() - start_time); | 130 base::TimeDelta delta(base::TimeTicks::Now() - start_time); |
| 133 HISTOGRAM_TIMES("SyncFileSystem.RegisterOriginTime", delta); | 131 HISTOGRAM_TIMES("SyncFileSystem.RegisterOriginTime", delta); |
| 134 callback.Run(status); | 132 callback.Run(status); |
| 135 } | 133 } |
| 136 | 134 |
| 137 } // namespace | 135 } // namespace |
| 138 | 136 |
| (...skipping 389 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 528 | 526 |
| 529 void SyncEngine::UpdateServiceState(RemoteServiceState state, | 527 void SyncEngine::UpdateServiceState(RemoteServiceState state, |
| 530 const std::string& description) { | 528 const std::string& description) { |
| 531 service_state_ = state; | 529 service_state_ = state; |
| 532 | 530 |
| 533 FOR_EACH_OBSERVER( | 531 FOR_EACH_OBSERVER( |
| 534 Observer, service_observers_, | 532 Observer, service_observers_, |
| 535 OnRemoteServiceStateUpdated(state, description)); | 533 OnRemoteServiceStateUpdated(state, description)); |
| 536 } | 534 } |
| 537 | 535 |
| 538 void SyncEngine::UpdateRegisteredAppsForTesting() { | |
| 539 if (!extension_service_) | |
| 540 return; | |
| 541 | |
| 542 MetadataDatabase* metadata_db = sync_worker_->GetMetadataDatabase(); | |
| 543 DCHECK(metadata_db); | |
| 544 std::vector<std::string> app_ids; | |
| 545 metadata_db->GetRegisteredAppIDs(&app_ids); | |
| 546 | |
| 547 // Update the status of every origin using status from ExtensionService. | |
| 548 for (std::vector<std::string>::const_iterator itr = app_ids.begin(); | |
| 549 itr != app_ids.end(); ++itr) { | |
| 550 const std::string& app_id = *itr; | |
| 551 GURL origin = | |
| 552 extensions::Extension::GetBaseURLFromExtensionId(app_id); | |
| 553 if (!extension_service_->GetInstalledExtension(app_id)) { | |
| 554 // Extension has been uninstalled. | |
| 555 // (At this stage we can't know if it was unpacked extension or not, | |
| 556 // so just purge the remote folder.) | |
| 557 UninstallOrigin(origin, | |
| 558 RemoteFileSyncService::UNINSTALL_AND_PURGE_REMOTE, | |
| 559 base::Bind(&EmptyStatusCallback)); | |
| 560 continue; | |
| 561 } | |
| 562 FileTracker tracker; | |
| 563 if (!metadata_db->FindAppRootTracker(app_id, &tracker)) { | |
| 564 // App will register itself on first run. | |
| 565 continue; | |
| 566 } | |
| 567 bool is_app_enabled = extension_service_->IsExtensionEnabled(app_id); | |
| 568 bool is_app_root_tracker_enabled = | |
| 569 tracker.tracker_kind() == TRACKER_KIND_APP_ROOT; | |
| 570 if (is_app_enabled && !is_app_root_tracker_enabled) | |
| 571 EnableOrigin(origin, base::Bind(&EmptyStatusCallback)); | |
| 572 else if (!is_app_enabled && is_app_root_tracker_enabled) | |
| 573 DisableOrigin(origin, base::Bind(&EmptyStatusCallback)); | |
| 574 } | |
| 575 } | |
| 576 | |
| 577 SyncStatusCallback SyncEngine::TrackCallback( | 536 SyncStatusCallback SyncEngine::TrackCallback( |
| 578 const SyncStatusCallback& callback) { | 537 const SyncStatusCallback& callback) { |
| 579 return callback_tracker_.Register( | 538 return callback_tracker_.Register( |
| 580 base::Bind(callback, SYNC_STATUS_ABORT), | 539 base::Bind(callback, SYNC_STATUS_ABORT), |
| 581 callback); | 540 callback); |
| 582 } | 541 } |
| 583 | 542 |
| 584 } // namespace drive_backend | 543 } // namespace drive_backend |
| 585 } // namespace sync_file_system | 544 } // namespace sync_file_system |
| OLD | NEW |