[Android] Only invalidate objects that were received from Tango on resume.

components/invalidation/invalidation_service_android.cc

 // 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.
 
 #include "components/invalidation/invalidation_service_android.h"
 
 #include "base/android/jni_android.h"
 #include "base/android/jni_array.h"
 #include "base/android/jni_string.h"
 #include "base/callback.h"
@@ skipping 101 matching lines @@
   return NULL;
 }
 
 void InvalidationServiceAndroid::TriggerStateChangeForTest(
     syncer::InvalidatorState state) {
   DCHECK(CalledOnValidThread());
   invalidator_state_ = state;
   invalidator_registrar_.UpdateInvalidatorState(invalidator_state_);
 }
 
-void InvalidationServiceAndroid::RequestSync(JNIEnv* env,
-                                             jobject obj,
-                                             jint object_source,
-                                             jstring java_object_id,
-                                             jlong version,
-                                             jstring java_state) {
-  invalidation::ObjectId object_id(object_source,
-      ConvertJavaStringToUTF8(env, java_object_id));
+void InvalidationServiceAndroid::Invalidate(JNIEnv* env,
+                                            jobject obj,
+                                            jint object_source,
+                                            jstring java_object_id,
+                                            jlong version,
+                                            jstring java_payload) {
+  syncer::ObjectIdInvalidationMap object_invalidation_map;
+  if (!java_object_id) {
+    syncer::ObjectIdSet sync_ids;
+    if (object_source == 0) {
+      sync_ids = invalidator_registrar_.GetAllRegisteredIds();
+    } else {
+      for (const auto& id : invalidator_registrar_.GetAllRegisteredIds()) {
+        if (id.source() == object_source)
+          sync_ids.insert(id);
+      }
+    }
+    object_invalidation_map =
+        syncer::ObjectIdInvalidationMap::InvalidateAll(sync_ids);
+  } else {
+    invalidation::ObjectId object_id(
+        object_source, ConvertJavaStringToUTF8(env, java_object_id));
+    syncer::ObjectIdInvalidationMap object_invalidation_map;
 
-  syncer::ObjectIdInvalidationMap object_ids_with_states;
-
-  if (version == ipc::invalidation::Constants::UNKNOWN) {
-    object_ids_with_states.Insert(
-        syncer::Invalidation::InitUnknownVersion(object_id));
-  } else {
-    ObjectIdVersionMap::iterator it =
-        max_invalidation_versions_.find(object_id);
-    if ((it != max_invalidation_versions_.end()) &&
-        (version <= it->second)) {
-      DVLOG(1) << "Dropping redundant invalidation with version " << version;
-      return;
+    if (version == ipc::invalidation::Constants::UNKNOWN) {
+      object_invalidation_map.Insert(
+          syncer::Invalidation::InitUnknownVersion(object_id));
+    } else {
+      ObjectIdVersionMap::iterator it =
+          max_invalidation_versions_.find(object_id);
+      if ((it != max_invalidation_versions_.end()) && (version <= it->second)) {
+        DVLOG(1) << "Dropping redundant invalidation with version " << version;
+        return;
+      }
+      max_invalidation_versions_[object_id] = version;
+      object_invalidation_map.Insert(syncer::Invalidation::Init(
+          object_id, version, ConvertJavaStringToUTF8(env, java_payload)));
     }
-    max_invalidation_versions_[object_id] = version;
-    object_ids_with_states.Insert(
-        syncer::Invalidation::Init(object_id, version,
-                                   ConvertJavaStringToUTF8(env, java_state)));
   }
 
-  DispatchInvalidations(object_ids_with_states);
-}
-
-void InvalidationServiceAndroid::RequestSyncForAllTypes(JNIEnv* env,
-                                                        jobject obj) {
-  syncer::ObjectIdInvalidationMap object_ids_with_states;
-  DispatchInvalidations(object_ids_with_states);
-}
-
-void InvalidationServiceAndroid::DispatchInvalidations(
-    syncer::ObjectIdInvalidationMap& object_invalidation_map) {
-  // An empty map implies that we should invalidate all.
-  const syncer::ObjectIdInvalidationMap& effective_invalidation_map =
-      object_invalidation_map.Empty() ?
-      syncer::ObjectIdInvalidationMap::InvalidateAll(
-          invalidator_registrar_.GetAllRegisteredIds()) :
-      object_invalidation_map;
-
   invalidator_registrar_.DispatchInvalidationsToHandlers(
-      effective_invalidation_map);
-  logger_.OnInvalidation(effective_invalidation_map);
+      object_invalidation_map);
+  logger_.OnInvalidation(object_invalidation_map);
 }
 
 // static
 bool InvalidationServiceAndroid::RegisterJni(JNIEnv* env) {
   return RegisterNativesImpl(env);
 }
 
 }  // namespace invalidation