Implement sync in the NonBlockingTypeProcessor

sync/sessions/model_type_registry_unittest.cc

Index: sync/sessions/model_type_registry_unittest.cc
diff --git a/sync/sessions/model_type_registry_unittest.cc b/sync/sessions/model_type_registry_unittest.cc
index 6b344ebf24c519bda894c4b284717f5d73f6ddcc..9efe76f48bb0c70442cf82aeef54b0c6cc62d28e 100644
--- a/sync/sessions/model_type_registry_unittest.cc
+++ b/sync/sessions/model_type_registry_unittest.cc
@@ -23,6 +23,14 @@ class ModelTypeRegistryTest : public ::testing::Test {
 
   ModelTypeRegistry* registry();
 
+  static DataTypeState MakeInitialDataTypeState(ModelType type) {
+    DataTypeState state;
+    state.progress_marker.set_data_type_id(
+        GetSpecificsFieldNumberFromModelType(type));
+    state.next_id = 0;
+    return state;
+  }
+
  private:
   syncable::Directory* directory();
 
@@ -139,13 +147,17 @@ TEST_F(ModelTypeRegistryTest, NonBlockingTypes) {
 
   EXPECT_TRUE(registry()->GetEnabledTypes().Empty());
 
-  registry()->InitializeNonBlockingType(
-      syncer::THEMES, task_runner, themes_processor.AsWeakPtrForUI());
+  registry()->InitializeNonBlockingType(syncer::THEMES,
+                                        MakeInitialDataTypeState(THEMES),
+                                        task_runner,
+                                        themes_processor.AsWeakPtrForUI());
   EXPECT_TRUE(registry()->GetEnabledTypes().Equals(
       ModelTypeSet(syncer::THEMES)));
 
-  registry()->InitializeNonBlockingType(
-      syncer::SESSIONS, task_runner, sessions_processor.AsWeakPtrForUI());
+  registry()->InitializeNonBlockingType(syncer::SESSIONS,
+                                        MakeInitialDataTypeState(SESSIONS),
+                                        task_runner,
+                                        sessions_processor.AsWeakPtrForUI());
   EXPECT_TRUE(registry()->GetEnabledTypes().Equals(
       ModelTypeSet(syncer::THEMES, syncer::SESSIONS)));
 
@@ -172,8 +184,10 @@ TEST_F(ModelTypeRegistryTest, NonBlockingTypesWithDirectoryTypes) {
   EXPECT_TRUE(registry()->GetEnabledTypes().Empty());
 
   // Add the themes non-blocking type.
-  registry()->InitializeNonBlockingType(
-      syncer::THEMES, task_runner, themes_processor.AsWeakPtrForUI());
+  registry()->InitializeNonBlockingType(syncer::THEMES,
+                                        MakeInitialDataTypeState(THEMES),
+                                        task_runner,
+                                        themes_processor.AsWeakPtrForUI());
   current_types.Put(syncer::THEMES);
   EXPECT_TRUE(registry()->GetEnabledTypes().Equals(current_types));
 
@@ -183,8 +197,10 @@ TEST_F(ModelTypeRegistryTest, NonBlockingTypesWithDirectoryTypes) {
   EXPECT_TRUE(registry()->GetEnabledTypes().Equals(current_types));
 
   // Add sessions non-blocking type.
-  registry()->InitializeNonBlockingType(
-      syncer::SESSIONS, task_runner, sessions_processor.AsWeakPtrForUI());
+  registry()->InitializeNonBlockingType(syncer::SESSIONS,
+                                        MakeInitialDataTypeState(SESSIONS),
+                                        task_runner,
+                                        sessions_processor.AsWeakPtrForUI());
   current_types.Put(syncer::SESSIONS);
   EXPECT_TRUE(registry()->GetEnabledTypes().Equals(current_types));
 
@@ -210,10 +226,14 @@ TEST_F(ModelTypeRegistryTest, DeletionOrdering) {
 
   EXPECT_TRUE(registry()->GetEnabledTypes().Empty());
 
-  registry()->InitializeNonBlockingType(
-      syncer::THEMES, task_runner, themes_processor->AsWeakPtrForUI());
-  registry()->InitializeNonBlockingType(
-      syncer::SESSIONS, task_runner, sessions_processor->AsWeakPtrForUI());
+  registry()->InitializeNonBlockingType(syncer::THEMES,
+                                        MakeInitialDataTypeState(THEMES),
+                                        task_runner,
+                                        themes_processor->AsWeakPtrForUI());
+  registry()->InitializeNonBlockingType(syncer::SESSIONS,
+                                        MakeInitialDataTypeState(SESSIONS),
+                                        task_runner,
+                                        sessions_processor->AsWeakPtrForUI());
   EXPECT_TRUE(registry()->GetEnabledTypes().Equals(
       ModelTypeSet(syncer::THEMES, syncer::SESSIONS)));