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

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

Issue 334053008: [SyncFS] Make task invocation in SyncTaskRunner async (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 6 years, 6 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 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 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_worker.h" 5 #include "chrome/browser/sync_file_system/drive_backend/sync_worker.h"
6 6
7 #include <vector> 7 #include <vector>
8 8
9 #include "base/bind.h" 9 #include "base/bind.h"
10 #include "chrome/browser/drive/drive_service_interface.h" 10 #include "chrome/browser/drive/drive_service_interface.h"
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after
63 observers_.Clear(); 63 observers_.Clear();
64 } 64 }
65 65
66 void SyncWorker::Initialize(scoped_ptr<SyncEngineContext> context) { 66 void SyncWorker::Initialize(scoped_ptr<SyncEngineContext> context) {
67 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 67 DCHECK(sequence_checker_.CalledOnValidSequencedThread());
68 DCHECK(!task_manager_); 68 DCHECK(!task_manager_);
69 69
70 context_ = context.Pass(); 70 context_ = context.Pass();
71 71
72 task_manager_.reset(new SyncTaskManager( 72 task_manager_.reset(new SyncTaskManager(
73 weak_ptr_factory_.GetWeakPtr(), 0 /* maximum_background_task */)); 73 weak_ptr_factory_.GetWeakPtr(), 0 /* maximum_background_task */,
74 context_->GetWorkerTaskRunner()));
74 task_manager_->Initialize(SYNC_STATUS_OK); 75 task_manager_->Initialize(SYNC_STATUS_OK);
75 76
76 PostInitializeTask(); 77 PostInitializeTask();
77 78
78 net::NetworkChangeNotifier::ConnectionType type = 79 net::NetworkChangeNotifier::ConnectionType type =
79 net::NetworkChangeNotifier::GetConnectionType(); 80 net::NetworkChangeNotifier::GetConnectionType();
80 network_available_ = 81 network_available_ =
81 type != net::NetworkChangeNotifier::CONNECTION_NONE; 82 type != net::NetworkChangeNotifier::CONNECTION_NONE;
82 } 83 }
83 84
(...skipping 657 matching lines...) Expand 10 before | Expand all | Expand 10 after
741 "Service state changed: %d->%d: %s", 742 "Service state changed: %d->%d: %s",
742 old_state, GetCurrentState(), description.c_str()); 743 old_state, GetCurrentState(), description.c_str());
743 744
744 FOR_EACH_OBSERVER( 745 FOR_EACH_OBSERVER(
745 Observer, observers_, 746 Observer, observers_,
746 UpdateServiceState(GetCurrentState(), description)); 747 UpdateServiceState(GetCurrentState(), description));
747 } 748 }
748 749
749 } // namespace drive_backend 750 } // namespace drive_backend
750 } // namespace sync_file_system 751 } // namespace sync_file_system
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698