Chromium Code Reviews| 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) {} |
|
peria
2014/09/04 09:47:48
|enabled| seems not to be used?
tzik
2014/09/04 10:57:07
Commented out. Our style guide (and linter) seems
| |
| 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 |