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 |