Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(201)

Side by Side Diff: chrome/browser/sync_file_system/drive_backend/sync_engine.cc

Issue 259503004: [SyncFS] Refine callback helpers (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 6 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
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
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
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
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
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698