sync: Implement fake server reflection blocking

chrome/browser/sync/test/integration/sync_test.cc

 // Copyright (c) 2012 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/sync_test.h"
 
 #include <vector>
 
 #include "base/basictypes.h"
 #include "base/bind.h"
@@ skipping 387 matching lines @@
 
 void SyncTest::InitializeInvalidations(int index) {
   if (server_type_ == IN_PROCESS_FAKE_SERVER) {
     CHECK(fake_server_.get());
     fake_server::FakeServerInvalidationService* invalidation_service =
         static_cast<fake_server::FakeServerInvalidationService*>(
             InvalidationServiceFactory::GetInstance()->SetTestingFactoryAndUse(
                 GetProfile(index),
                 fake_server::FakeServerInvalidationService::Build));
     fake_server_->AddObserver(invalidation_service);
+    invalidation_service->SetSelfNotificationsEnabled(
+        TestUsesSelfNotifications());
     fake_server_invalidation_services_[index] = invalidation_service;
   } else {
     invalidation::P2PInvalidationService* p2p_invalidation_service =
         static_cast<invalidation::P2PInvalidationService*>(
             InvalidationServiceFactory::GetInstance()->SetTestingFactoryAndUse(
                 GetProfile(index),
                 TestUsesSelfNotifications() ?
                     BuildSelfNotifyingP2PInvalidationService
                     : BuildRealisticP2PInvalidationService));
     p2p_invalidation_service->UpdateCredentials(username_, password_);
@@ skipping 626 matching lines @@
   BrowserThread::PostTask(
       BrowserThread::IO, FROM_HERE,
       base::Bind(&SetProxyConfigCallback, &done,
                  make_scoped_refptr(context_getter), proxy_config));
   done.Wait();
 }
 
 fake_server::FakeServer* SyncTest::GetFakeServer() const {
   return fake_server_.get();
 }