| 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 219 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 230 DCHECK(factories); | 230 DCHECK(factories); |
| 231 factories->insert(drive::DriveNotificationManagerFactory::GetInstance()); | 231 factories->insert(drive::DriveNotificationManagerFactory::GetInstance()); |
| 232 factories->insert(SigninManagerFactory::GetInstance()); | 232 factories->insert(SigninManagerFactory::GetInstance()); |
| 233 factories->insert( | 233 factories->insert( |
| 234 extensions::ExtensionsBrowserClient::Get()->GetExtensionSystemFactory()); | 234 extensions::ExtensionsBrowserClient::Get()->GetExtensionSystemFactory()); |
| 235 factories->insert(ProfileOAuth2TokenServiceFactory::GetInstance()); | 235 factories->insert(ProfileOAuth2TokenServiceFactory::GetInstance()); |
| 236 } | 236 } |
| 237 | 237 |
| 238 SyncEngine::~SyncEngine() { | 238 SyncEngine::~SyncEngine() { |
| 239 net::NetworkChangeNotifier::RemoveNetworkChangeObserver(this); | 239 net::NetworkChangeNotifier::RemoveNetworkChangeObserver(this); |
| 240 GetDriveService()->RemoveObserver(this); | 240 drive_service_->RemoveObserver(this); |
| 241 if (notification_manager_) | 241 if (notification_manager_) |
| 242 notification_manager_->RemoveObserver(this); | 242 notification_manager_->RemoveObserver(this); |
| 243 | 243 |
| 244 DeleteSoon(FROM_HERE, worker_task_runner_, worker_observer_.Pass()); | 244 DeleteSoon(FROM_HERE, worker_task_runner_, worker_observer_.Pass()); |
| 245 DeleteSoon(FROM_HERE, worker_task_runner_, sync_worker_.Pass()); | 245 DeleteSoon(FROM_HERE, worker_task_runner_, sync_worker_.Pass()); |
| 246 DeleteSoon(FROM_HERE, worker_task_runner_, | 246 DeleteSoon(FROM_HERE, worker_task_runner_, |
| 247 remote_change_processor_on_worker_.Pass()); | 247 remote_change_processor_on_worker_.Pass()); |
| 248 } | 248 } |
| 249 | 249 |
| 250 void SyncEngine::Initialize(const base::FilePath& base_dir, | 250 void SyncEngine::Initialize(const base::FilePath& base_dir, |
| (...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 283 sync_engine_context.Pass(), | 283 sync_engine_context.Pass(), |
| 284 env_override)); | 284 env_override)); |
| 285 sync_worker_->AddObserver(worker_observer_.get()); | 285 sync_worker_->AddObserver(worker_observer_.get()); |
| 286 worker_task_runner_->PostTask( | 286 worker_task_runner_->PostTask( |
| 287 FROM_HERE, | 287 FROM_HERE, |
| 288 base::Bind(&SyncWorker::Initialize, | 288 base::Bind(&SyncWorker::Initialize, |
| 289 base::Unretained(sync_worker_.get()))); | 289 base::Unretained(sync_worker_.get()))); |
| 290 | 290 |
| 291 if (notification_manager_) | 291 if (notification_manager_) |
| 292 notification_manager_->AddObserver(this); | 292 notification_manager_->AddObserver(this); |
| 293 GetDriveService()->AddObserver(this); | 293 drive_service_->AddObserver(this); |
| 294 net::NetworkChangeNotifier::AddNetworkChangeObserver(this); | 294 net::NetworkChangeNotifier::AddNetworkChangeObserver(this); |
| 295 } | 295 } |
| 296 | 296 |
| 297 void SyncEngine::AddServiceObserver(SyncServiceObserver* observer) { | 297 void SyncEngine::AddServiceObserver(SyncServiceObserver* observer) { |
| 298 service_observers_.AddObserver(observer); | 298 service_observers_.AddObserver(observer); |
| 299 } | 299 } |
| 300 | 300 |
| 301 void SyncEngine::AddFileStatusObserver(FileStatusObserver* observer) { | 301 void SyncEngine::AddFileStatusObserver(FileStatusObserver* observer) { |
| 302 file_status_observers_.AddObserver(observer); | 302 file_status_observers_.AddObserver(observer); |
| 303 } | 303 } |
| (...skipping 198 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 502 | 502 |
| 503 void SyncEngine::OnNetworkChanged( | 503 void SyncEngine::OnNetworkChanged( |
| 504 net::NetworkChangeNotifier::ConnectionType type) { | 504 net::NetworkChangeNotifier::ConnectionType type) { |
| 505 worker_task_runner_->PostTask( | 505 worker_task_runner_->PostTask( |
| 506 FROM_HERE, | 506 FROM_HERE, |
| 507 base::Bind(&SyncWorker::OnNetworkChanged, | 507 base::Bind(&SyncWorker::OnNetworkChanged, |
| 508 base::Unretained(sync_worker_.get()), | 508 base::Unretained(sync_worker_.get()), |
| 509 type)); | 509 type)); |
| 510 } | 510 } |
| 511 | 511 |
| 512 drive::DriveServiceInterface* SyncEngine::GetDriveService() { | |
| 513 return drive_service_.get(); | |
| 514 } | |
| 515 | |
| 516 drive::DriveUploaderInterface* SyncEngine::GetDriveUploader() { | |
| 517 return drive_uploader_.get(); | |
| 518 } | |
| 519 | |
| 520 SyncEngine::SyncEngine( | 512 SyncEngine::SyncEngine( |
| 521 scoped_ptr<drive::DriveServiceInterface> drive_service, | 513 scoped_ptr<drive::DriveServiceInterface> drive_service, |
| 522 scoped_ptr<drive::DriveUploaderInterface> drive_uploader, | 514 scoped_ptr<drive::DriveUploaderInterface> drive_uploader, |
| 523 base::SequencedTaskRunner* worker_task_runner, | 515 base::SequencedTaskRunner* worker_task_runner, |
| 524 drive::DriveNotificationManager* notification_manager, | 516 drive::DriveNotificationManager* notification_manager, |
| 525 ExtensionServiceInterface* extension_service, | 517 ExtensionServiceInterface* extension_service, |
| 526 SigninManagerBase* signin_manager) | 518 SigninManagerBase* signin_manager) |
| 527 : drive_service_(drive_service.Pass()), | 519 : drive_service_(drive_service.Pass()), |
| 528 drive_service_wrapper_(new DriveServiceWrapper(drive_service_.get())), | 520 drive_service_wrapper_(new DriveServiceWrapper(drive_service_.get())), |
| 529 drive_uploader_(drive_uploader.Pass()), | 521 drive_uploader_(drive_uploader.Pass()), |
| (...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 563 | 555 |
| 564 SyncStatusCallback SyncEngine::TrackCallback( | 556 SyncStatusCallback SyncEngine::TrackCallback( |
| 565 const SyncStatusCallback& callback) { | 557 const SyncStatusCallback& callback) { |
| 566 return callback_tracker_.Register( | 558 return callback_tracker_.Register( |
| 567 base::Bind(callback, SYNC_STATUS_ABORT), | 559 base::Bind(callback, SYNC_STATUS_ABORT), |
| 568 callback); | 560 callback); |
| 569 } | 561 } |
| 570 | 562 |
| 571 } // namespace drive_backend | 563 } // namespace drive_backend |
| 572 } // namespace sync_file_system | 564 } // namespace sync_file_system |
| OLD | NEW |