diff options
Diffstat (limited to 'sync/sessions/model_type_registry.cc')
-rw-r--r-- | sync/sessions/model_type_registry.cc | 21 |
1 files changed, 5 insertions, 16 deletions
diff --git a/sync/sessions/model_type_registry.cc b/sync/sessions/model_type_registry.cc index c2ba5f4..5222202 100644 --- a/sync/sessions/model_type_registry.cc +++ b/sync/sessions/model_type_registry.cc @@ -15,7 +15,6 @@ #include "sync/engine/model_type_sync_worker_impl.h" #include "sync/internal_api/public/non_blocking_sync_common.h" #include "sync/sessions/directory_type_debug_info_emitter.h" -#include "sync/util/cryptographer.h" namespace syncer { @@ -33,8 +32,7 @@ class ModelTypeSyncProxyWrapper : public ModelTypeSyncProxy { const CommitResponseDataList& response_list) OVERRIDE; virtual void OnUpdateReceived( const DataTypeState& type_state, - const UpdateResponseDataList& response_list, - const UpdateResponseDataList& pending_updates) OVERRIDE; + const UpdateResponseDataList& response_list) OVERRIDE; private: base::WeakPtr<ModelTypeSyncProxyImpl> processor_; @@ -63,15 +61,13 @@ void ModelTypeSyncProxyWrapper::OnCommitCompleted( void ModelTypeSyncProxyWrapper::OnUpdateReceived( const DataTypeState& type_state, - const UpdateResponseDataList& response_list, - const UpdateResponseDataList& pending_updates) { + const UpdateResponseDataList& response_list) { processor_task_runner_->PostTask( FROM_HERE, base::Bind(&ModelTypeSyncProxyImpl::OnUpdateReceived, processor_, type_state, - response_list, - pending_updates)); + response_list)); } class ModelTypeSyncWorkerWrapper : public ModelTypeSyncWorker { @@ -111,7 +107,6 @@ ModelTypeRegistry::ModelTypeRegistry( syncable::Directory* directory, NudgeHandler* nudge_handler) : directory_(directory), - cryptographer_provider_(directory_), nudge_handler_(nudge_handler), weak_ptr_factory_(this) { for (size_t i = 0u; i < workers.size(); ++i) { @@ -190,7 +185,6 @@ void ModelTypeRegistry::SetEnabledDirectoryTypes( void ModelTypeRegistry::ConnectSyncTypeToWorker( ModelType type, const DataTypeState& data_type_state, - const UpdateResponseDataList& saved_pending_updates, const scoped_refptr<base::SequencedTaskRunner>& type_task_runner, const base::WeakPtr<ModelTypeSyncProxyImpl>& proxy_impl) { DVLOG(1) << "Enabling an off-thread sync type: " << ModelTypeToString(type); @@ -198,13 +192,8 @@ void ModelTypeRegistry::ConnectSyncTypeToWorker( // Initialize Worker -> Proxy communication channel. scoped_ptr<ModelTypeSyncProxy> proxy( new ModelTypeSyncProxyWrapper(proxy_impl, type_task_runner)); - scoped_ptr<ModelTypeSyncWorkerImpl> worker( - new ModelTypeSyncWorkerImpl(type, - data_type_state, - saved_pending_updates, - &cryptographer_provider_, - nudge_handler_, - proxy.Pass())); + scoped_ptr<ModelTypeSyncWorkerImpl> worker(new ModelTypeSyncWorkerImpl( + type, data_type_state, nudge_handler_, proxy.Pass())); // Initialize Proxy -> Worker communication channel. scoped_ptr<ModelTypeSyncWorker> wrapped_worker( |