sync: Implement fake server reflection blocking

chrome/browser/sync/test/integration/fake_server_invalidation_service.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 "chrome/browser/sync/test/integration/fake_server_invalidation_service.h"
 
 #include <string>
 
 #include "base/macros.h"
 #include "components/invalidation/invalidation_service_util.h"
 #include "sync/internal_api/public/base/invalidation.h"
 #include "sync/internal_api/public/base/model_type.h"
 #include "sync/notifier/object_id_invalidation_map.h"
 #
 
 namespace fake_server {
 
 FakeServerInvalidationService::FakeServerInvalidationService()
     : client_id_(invalidation::GenerateInvalidatorClientId()),
+      self_notify_(true),
       identity_provider_(&token_service_) {
   invalidator_registrar_.UpdateInvalidatorState(syncer::INVALIDATIONS_ENABLED);
 }
 
 FakeServerInvalidationService::~FakeServerInvalidationService() {
 }
 
 // static
 KeyedService* FakeServerInvalidationService::Build(
     content::BrowserContext* context) {
@@ skipping 33 matching lines @@
 void FakeServerInvalidationService::RequestDetailedStatus(
     base::Callback<void(const base::DictionaryValue&)> caller) const {
   base::DictionaryValue value;
   caller.Run(value);
 }
 
 IdentityProvider* FakeServerInvalidationService::GetIdentityProvider() {
   return &identity_provider_;
 }
 
+void FakeServerInvalidationService::EnableSelfNotifications() {
+  self_notify_ = true;
+}
+
+void FakeServerInvalidationService::DisableSelfNotifications() {
+  self_notify_ = false;
+}
+
 void FakeServerInvalidationService::OnCommit(
+    const std::string& committer_id,
     syncer::ModelTypeSet committed_model_types) {
   syncer::ObjectIdSet object_ids = syncer::ModelTypeSetToObjectIdSet(
       committed_model_types);
   syncer::ObjectIdInvalidationMap invalidation_map;
   for (syncer::ObjectIdSet::const_iterator it = object_ids.begin();
        it != object_ids.end(); ++it) {
     // TODO(pvalenzuela): Create more refined invalidations instead of
     // invalidating all items of a given type.
-    invalidation_map.Insert(syncer::Invalidation::InitUnknownVersion(*it));
+
+    if (self_notify_ || client_id_ != committer_id) {
+      invalidation_map.Insert(syncer::Invalidation::InitUnknownVersion(*it));
+    }
   }
   invalidator_registrar_.DispatchInvalidationsToHandlers(invalidation_map);
 }
 
 }  // namespace fake_server