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