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 340 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
351 FROM_HERE, | 351 FROM_HERE, |
352 base::Bind(&SyncWorkerInterface::Initialize, | 352 base::Bind(&SyncWorkerInterface::Initialize, |
353 base::Unretained(sync_worker_.get()), | 353 base::Unretained(sync_worker_.get()), |
354 base::Passed(&sync_engine_context))); | 354 base::Passed(&sync_engine_context))); |
355 if (remote_change_processor_) | 355 if (remote_change_processor_) |
356 SetRemoteChangeProcessor(remote_change_processor_); | 356 SetRemoteChangeProcessor(remote_change_processor_); |
357 | 357 |
358 drive_service_->AddObserver(this); | 358 drive_service_->AddObserver(this); |
359 | 359 |
360 service_state_ = REMOTE_SERVICE_TEMPORARY_UNAVAILABLE; | 360 service_state_ = REMOTE_SERVICE_TEMPORARY_UNAVAILABLE; |
361 SetSyncEnabled(sync_enabled_); | |
362 OnNetworkChanged(net::NetworkChangeNotifier::GetConnectionType()); | 361 OnNetworkChanged(net::NetworkChangeNotifier::GetConnectionType()); |
363 if (drive_service_->HasRefreshToken()) | 362 if (drive_service_->HasRefreshToken()) |
364 OnReadyToSendRequests(); | 363 OnReadyToSendRequests(); |
365 else | 364 else |
366 OnRefreshTokenInvalid(); | 365 OnRefreshTokenInvalid(); |
367 } | 366 } |
368 | 367 |
369 void SyncEngine::AddServiceObserver(SyncServiceObserver* observer) { | 368 void SyncEngine::AddServiceObserver(SyncServiceObserver* observer) { |
370 service_observers_.AddObserver(observer); | 369 service_observers_.AddObserver(observer); |
371 } | 370 } |
(...skipping 286 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
658 return; | 657 return; |
659 | 658 |
660 worker_task_runner_->PostTask( | 659 worker_task_runner_->PostTask( |
661 FROM_HERE, | 660 FROM_HERE, |
662 base::Bind(&SyncWorkerInterface::ActivateService, | 661 base::Bind(&SyncWorkerInterface::ActivateService, |
663 base::Unretained(sync_worker_.get()), | 662 base::Unretained(sync_worker_.get()), |
664 REMOTE_SERVICE_OK, | 663 REMOTE_SERVICE_OK, |
665 "Got push notification for Drive")); | 664 "Got push notification for Drive")); |
666 } | 665 } |
667 | 666 |
668 void SyncEngine::OnPushNotificationEnabled(bool) {} | 667 void SyncEngine::OnPushNotificationEnabled(bool /* enabled */) {} |
669 | 668 |
670 void SyncEngine::OnReadyToSendRequests() { | 669 void SyncEngine::OnReadyToSendRequests() { |
671 has_refresh_token_ = true; | 670 has_refresh_token_ = true; |
672 if (!sync_worker_) | 671 if (!sync_worker_) |
673 return; | 672 return; |
674 | 673 |
675 worker_task_runner_->PostTask( | 674 worker_task_runner_->PostTask( |
676 FROM_HERE, | 675 FROM_HERE, |
677 base::Bind(&SyncWorkerInterface::ActivateService, | 676 base::Bind(&SyncWorkerInterface::ActivateService, |
678 base::Unretained(sync_worker_.get()), | 677 base::Unretained(sync_worker_.get()), |
(...skipping 124 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
803 | 802 |
804 SyncStatusCallback SyncEngine::TrackCallback( | 803 SyncStatusCallback SyncEngine::TrackCallback( |
805 const SyncStatusCallback& callback) { | 804 const SyncStatusCallback& callback) { |
806 return callback_tracker_.Register( | 805 return callback_tracker_.Register( |
807 base::Bind(callback, SYNC_STATUS_ABORT), | 806 base::Bind(callback, SYNC_STATUS_ABORT), |
808 callback); | 807 callback); |
809 } | 808 } |
810 | 809 |
811 } // namespace drive_backend | 810 } // namespace drive_backend |
812 } // namespace sync_file_system | 811 } // namespace sync_file_system |
OLD | NEW |