| 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/threading/sequenced_worker_pool.h" | 10 #include "base/threading/sequenced_worker_pool.h" |
| (...skipping 202 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 213 void SyncEngine::AddFileStatusObserver(FileStatusObserver* observer) { | 213 void SyncEngine::AddFileStatusObserver(FileStatusObserver* observer) { |
| 214 file_status_observers_.AddObserver(observer); | 214 file_status_observers_.AddObserver(observer); |
| 215 } | 215 } |
| 216 | 216 |
| 217 void SyncEngine::RegisterOrigin( | 217 void SyncEngine::RegisterOrigin( |
| 218 const GURL& origin, const SyncStatusCallback& callback) { | 218 const GURL& origin, const SyncStatusCallback& callback) { |
| 219 worker_task_runner_->PostTask( | 219 worker_task_runner_->PostTask( |
| 220 FROM_HERE, | 220 FROM_HERE, |
| 221 base::Bind(&SyncWorker::RegisterOrigin, | 221 base::Bind(&SyncWorker::RegisterOrigin, |
| 222 base::Unretained(sync_worker_.get()), | 222 base::Unretained(sync_worker_.get()), |
| 223 origin, CreateRelayedCallback(callback))); | 223 origin, |
| 224 RelayCallbackToCurrentThread( |
| 225 FROM_HERE, callback))); |
| 224 } | 226 } |
| 225 | 227 |
| 226 void SyncEngine::EnableOrigin( | 228 void SyncEngine::EnableOrigin( |
| 227 const GURL& origin, const SyncStatusCallback& callback) { | 229 const GURL& origin, const SyncStatusCallback& callback) { |
| 228 worker_task_runner_->PostTask( | 230 worker_task_runner_->PostTask( |
| 229 FROM_HERE, | 231 FROM_HERE, |
| 230 base::Bind(&SyncWorker::EnableOrigin, | 232 base::Bind(&SyncWorker::EnableOrigin, |
| 231 base::Unretained(sync_worker_.get()), | 233 base::Unretained(sync_worker_.get()), |
| 232 origin, CreateRelayedCallback(callback))); | 234 origin, |
| 235 RelayCallbackToCurrentThread( |
| 236 FROM_HERE, callback))); |
| 233 } | 237 } |
| 234 | 238 |
| 235 void SyncEngine::DisableOrigin( | 239 void SyncEngine::DisableOrigin( |
| 236 const GURL& origin, const SyncStatusCallback& callback) { | 240 const GURL& origin, const SyncStatusCallback& callback) { |
| 237 worker_task_runner_->PostTask( | 241 worker_task_runner_->PostTask( |
| 238 FROM_HERE, | 242 FROM_HERE, |
| 239 base::Bind(&SyncWorker::DisableOrigin, | 243 base::Bind(&SyncWorker::DisableOrigin, |
| 240 base::Unretained(sync_worker_.get()), | 244 base::Unretained(sync_worker_.get()), |
| 241 origin, CreateRelayedCallback(callback))); | 245 origin, |
| 246 RelayCallbackToCurrentThread( |
| 247 FROM_HERE, callback))); |
| 242 } | 248 } |
| 243 | 249 |
| 244 void SyncEngine::UninstallOrigin( | 250 void SyncEngine::UninstallOrigin( |
| 245 const GURL& origin, | 251 const GURL& origin, |
| 246 UninstallFlag flag, | 252 UninstallFlag flag, |
| 247 const SyncStatusCallback& callback) { | 253 const SyncStatusCallback& callback) { |
| 248 worker_task_runner_->PostTask( | 254 worker_task_runner_->PostTask( |
| 249 FROM_HERE, | 255 FROM_HERE, |
| 250 base::Bind(&SyncWorker::UninstallOrigin, | 256 base::Bind(&SyncWorker::UninstallOrigin, |
| 251 base::Unretained(sync_worker_.get()), | 257 base::Unretained(sync_worker_.get()), |
| 252 origin, flag, CreateRelayedCallback(callback))); | 258 origin, flag, |
| 259 RelayCallbackToCurrentThread( |
| 260 FROM_HERE, callback))); |
| 253 } | 261 } |
| 254 | 262 |
| 255 void SyncEngine::ProcessRemoteChange(const SyncFileCallback& callback) { | 263 void SyncEngine::ProcessRemoteChange(const SyncFileCallback& callback) { |
| 256 worker_task_runner_->PostTask( | 264 worker_task_runner_->PostTask( |
| 257 FROM_HERE, | 265 FROM_HERE, |
| 258 base::Bind(&SyncWorker::ProcessRemoteChange, | 266 base::Bind(&SyncWorker::ProcessRemoteChange, |
| 259 base::Unretained(sync_worker_.get()), | 267 base::Unretained(sync_worker_.get()), |
| 260 CreateRelayedCallback(callback))); | 268 RelayCallbackToCurrentThread( |
| 269 FROM_HERE, callback))); |
| 261 } | 270 } |
| 262 | 271 |
| 263 void SyncEngine::SetRemoteChangeProcessor(RemoteChangeProcessor* processor) { | 272 void SyncEngine::SetRemoteChangeProcessor(RemoteChangeProcessor* processor) { |
| 264 worker_task_runner_->PostTask( | 273 worker_task_runner_->PostTask( |
| 265 FROM_HERE, | 274 FROM_HERE, |
| 266 base::Bind(&SyncWorker::SetRemoteChangeProcessor, | 275 base::Bind(&SyncWorker::SetRemoteChangeProcessor, |
| 267 base::Unretained(sync_worker_.get()), | 276 base::Unretained(sync_worker_.get()), |
| 268 processor)); | 277 processor)); |
| 269 } | 278 } |
| 270 | 279 |
| (...skipping 99 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 370 const fileapi::FileSystemURL& url, | 379 const fileapi::FileSystemURL& url, |
| 371 const SyncStatusCallback& callback) { | 380 const SyncStatusCallback& callback) { |
| 372 worker_task_runner_->PostTask( | 381 worker_task_runner_->PostTask( |
| 373 FROM_HERE, | 382 FROM_HERE, |
| 374 base::Bind(&SyncWorker::ApplyLocalChange, | 383 base::Bind(&SyncWorker::ApplyLocalChange, |
| 375 base::Unretained(sync_worker_.get()), | 384 base::Unretained(sync_worker_.get()), |
| 376 local_change, | 385 local_change, |
| 377 local_path, | 386 local_path, |
| 378 local_metadata, | 387 local_metadata, |
| 379 url, | 388 url, |
| 380 CreateRelayedCallback(callback))); | 389 RelayCallbackToCurrentThread( |
| 390 FROM_HERE, callback))); |
| 381 } | 391 } |
| 382 | 392 |
| 383 SyncTaskManager* SyncEngine::GetSyncTaskManagerForTesting() { | 393 SyncTaskManager* SyncEngine::GetSyncTaskManagerForTesting() { |
| 384 // TODO(peria): Post task | 394 // TODO(peria): Post task |
| 385 return sync_worker_->GetSyncTaskManager(); | 395 return sync_worker_->GetSyncTaskManager(); |
| 386 } | 396 } |
| 387 | 397 |
| 388 void SyncEngine::OnNotificationReceived() { | 398 void SyncEngine::OnNotificationReceived() { |
| 389 worker_task_runner_->PostTask( | 399 worker_task_runner_->PostTask( |
| 390 FROM_HERE, | 400 FROM_HERE, |
| (...skipping 116 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 507 tracker.tracker_kind() == TRACKER_KIND_APP_ROOT; | 517 tracker.tracker_kind() == TRACKER_KIND_APP_ROOT; |
| 508 if (is_app_enabled && !is_app_root_tracker_enabled) | 518 if (is_app_enabled && !is_app_root_tracker_enabled) |
| 509 EnableOrigin(origin, base::Bind(&EmptyStatusCallback)); | 519 EnableOrigin(origin, base::Bind(&EmptyStatusCallback)); |
| 510 else if (!is_app_enabled && is_app_root_tracker_enabled) | 520 else if (!is_app_enabled && is_app_root_tracker_enabled) |
| 511 DisableOrigin(origin, base::Bind(&EmptyStatusCallback)); | 521 DisableOrigin(origin, base::Bind(&EmptyStatusCallback)); |
| 512 } | 522 } |
| 513 } | 523 } |
| 514 | 524 |
| 515 } // namespace drive_backend | 525 } // namespace drive_backend |
| 516 } // namespace sync_file_system | 526 } // namespace sync_file_system |
| OLD | NEW |