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 |