| 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 "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/threading/sequenced_worker_pool.h" | 8 #include "base/threading/sequenced_worker_pool.h" |
| 9 #include "base/values.h" | 9 #include "base/values.h" |
| 10 #include "chrome/browser/drive/drive_api_service.h" | 10 #include "chrome/browser/drive/drive_api_service.h" |
| (...skipping 193 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 204 const GURL& origin, | 204 const GURL& origin, |
| 205 UninstallFlag flag, | 205 UninstallFlag flag, |
| 206 const SyncStatusCallback& callback) { | 206 const SyncStatusCallback& callback) { |
| 207 task_manager_->ScheduleSyncTask( | 207 task_manager_->ScheduleSyncTask( |
| 208 scoped_ptr<SyncTask>(new UninstallAppTask(this, origin.host(), flag)), | 208 scoped_ptr<SyncTask>(new UninstallAppTask(this, origin.host(), flag)), |
| 209 callback); | 209 callback); |
| 210 } | 210 } |
| 211 | 211 |
| 212 void SyncEngine::ProcessRemoteChange( | 212 void SyncEngine::ProcessRemoteChange( |
| 213 const SyncFileCallback& callback) { | 213 const SyncFileCallback& callback) { |
| 214 RemoteToLocalSyncer* syncer = new RemoteToLocalSyncer( | 214 RemoteToLocalSyncer* syncer = new RemoteToLocalSyncer(this); |
| 215 this, RemoteToLocalSyncer::PRIORITY_NORMAL); | |
| 216 task_manager_->ScheduleSyncTask( | 215 task_manager_->ScheduleSyncTask( |
| 217 scoped_ptr<SyncTask>(syncer), | 216 scoped_ptr<SyncTask>(syncer), |
| 218 base::Bind(&SyncEngine::DidProcessRemoteChange, | 217 base::Bind(&SyncEngine::DidProcessRemoteChange, |
| 219 weak_ptr_factory_.GetWeakPtr(), | 218 weak_ptr_factory_.GetWeakPtr(), |
| 220 syncer, callback)); | 219 syncer, callback)); |
| 221 } | 220 } |
| 222 | 221 |
| 223 void SyncEngine::SetRemoteChangeProcessor( | 222 void SyncEngine::SetRemoteChangeProcessor( |
| 224 RemoteChangeProcessor* processor) { | 223 RemoteChangeProcessor* processor) { |
| 225 remote_change_processor_ = processor; | 224 remote_change_processor_ = processor; |
| (...skipping 337 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 563 tracker.tracker_kind() == TRACKER_KIND_APP_ROOT; | 562 tracker.tracker_kind() == TRACKER_KIND_APP_ROOT; |
| 564 if (is_app_enabled && !is_app_root_tracker_enabled) | 563 if (is_app_enabled && !is_app_root_tracker_enabled) |
| 565 EnableOrigin(origin, base::Bind(&EmptyStatusCallback)); | 564 EnableOrigin(origin, base::Bind(&EmptyStatusCallback)); |
| 566 else if (!is_app_enabled && is_app_root_tracker_enabled) | 565 else if (!is_app_enabled && is_app_root_tracker_enabled) |
| 567 DisableOrigin(origin, base::Bind(&EmptyStatusCallback)); | 566 DisableOrigin(origin, base::Bind(&EmptyStatusCallback)); |
| 568 } | 567 } |
| 569 } | 568 } |
| 570 | 569 |
| 571 } // namespace drive_backend | 570 } // namespace drive_backend |
| 572 } // namespace sync_file_system | 571 } // namespace sync_file_system |
| OLD | NEW |