Implement sync in the NonBlockingTypeProcessor

sync/sessions/model_type_registry.h

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #ifndef SYNC_ENGINE_MODEL_TYPE_REGISTRY_H_
 #define SYNC_ENGINE_MODEL_TYPE_REGISTRY_H_
 
 #include <map>
 
 #include "base/basictypes.h"
@@ skipping 10 matching lines @@
 class Directory;
 }  // namespace syncable
 
 class CommitContributor;
 class DirectoryCommitContributor;
 class DirectoryUpdateHandler;
 class DirectoryTypeDebugInfoEmitter;
 class NonBlockingTypeProcessorCore;
 class NonBlockingTypeProcessor;
 class UpdateHandler;
+struct DataTypeState;
 
 typedef std::map<ModelType, UpdateHandler*> UpdateHandlerMap;
 typedef std::map<ModelType, CommitContributor*> CommitContributorMap;
 typedef std::map<ModelType, DirectoryTypeDebugInfoEmitter*>
     DirectoryTypeDebugInfoEmitterMap;
 
 // Keeps track of the sets of active update handlers and commit contributors.
 class SYNC_EXPORT_PRIVATE ModelTypeRegistry {
  public:
   // This alternative constructor does not support any directory types.
   // It is used only in tests.
   ModelTypeRegistry();
 
   // Constructs a ModelTypeRegistry that supports directory types.
   ModelTypeRegistry(
       const std::vector<scoped_refptr<ModelSafeWorker> >& workers,
       syncable::Directory* directory);
   ~ModelTypeRegistry();
 
   // Sets the set of enabled types.
   void SetEnabledDirectoryTypes(const ModelSafeRoutingInfo& routing_info);
 
   // Enables an off-thread type for syncing.  Connects the given processor
   // and its task_runner to the newly created processor core.
   //
   // Expects that the processor's ModelType is not currently enabled.
   void InitializeNonBlockingType(
       syncer::ModelType type,
+      const DataTypeState& data_type_state,
       scoped_refptr<base::SequencedTaskRunner> type_task_runner,
       base::WeakPtr<NonBlockingTypeProcessor> processor);
 
   // Disables the syncing of an off-thread type.
   //
   // Expects that the type is currently enabled.
   // Deletes the processor core associated with the type.
   void RemoveNonBlockingType(syncer::ModelType type);
 
   // Gets the set of enabled types.
@@ skipping 51 matching lines @@
   // guaranteed to live as long as this sync backend.
   ObserverList<TypeDebugInfoObserver> type_debug_info_observers_;
 
   DISALLOW_COPY_AND_ASSIGN(ModelTypeRegistry);
 };
 
 }  // namespace syncer
 
 #endif // SYNC_ENGINE_MODEL_TYPE_REGISTRY_H_