sync: Implement per-type update processing

sync/test/engine/mock_connection_manager.cc

Index: sync/test/engine/mock_connection_manager.cc
diff --git a/sync/test/engine/mock_connection_manager.cc b/sync/test/engine/mock_connection_manager.cc
index 2290fea35cf2f281853637a0bb706e932b451ae0..624e02218822a9c2fc9509f10280222fbabb5915 100644
--- a/sync/test/engine/mock_connection_manager.cc
+++ b/sync/test/engine/mock_connection_manager.cc
@@ -533,12 +533,10 @@ void MockConnectionManager::ProcessGetUpdates(
   std::string token = response->get_updates().new_progress_marker(0).token();
   response->mutable_get_updates()->clear_new_progress_marker();
   for (int i = 0; i < gu.from_progress_marker_size(); ++i) {
-    if (gu.from_progress_marker(i).token() != token) {
-      sync_pb::DataTypeProgressMarker* new_marker =
-          response->mutable_get_updates()->add_new_progress_marker();
-      new_marker->set_data_type_id(gu.from_progress_marker(i).data_type_id());
-      new_marker->set_token(token);
-    }
+    sync_pb::DataTypeProgressMarker* new_marker =
+        response->mutable_get_updates()->add_new_progress_marker();
+    new_marker->set_data_type_id(gu.from_progress_marker(i).data_type_id());
+    new_marker->set_token(token);
   }
 
   // Fill the keystore key if requested.