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 |