Browser test for the push messaging feature

chrome/browser/sync/profile_sync_service.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/profile_sync_service.h"
 
 #include <cstddef>
 #include <map>
 #include <set>
 #include <utility>
@@ skipping 454 matching lines @@
 
 void ProfileSyncService::UnregisterInvalidationHandler(
     syncer::InvalidationHandler* handler) {
   invalidator_registrar_.UnregisterHandler(handler);
 }
 
 syncer::InvalidatorState ProfileSyncService::GetInvalidatorState() const {
   return invalidator_registrar_.GetInvalidatorState();
 }
 
+// test method for system test to allow a test to send in an invalidation

[Mihai Parparita -not on Chrome, 2012/09/14 20:02:49]

More comments that need to be capitalized and end with a period.

+void ProfileSyncService::SendInvalidationForTest(
+    const std::string& id_name,
+    const std::string& payload) {
+  // the list of ids to notify
+  syncer::ObjectIdSet notify_ids;
+
+  // find a registered id (if any) with the same name
+  syncer::ObjectIdSet registered_ids =
+      invalidator_registrar_.GetAllRegisteredIds();
+  syncer::ObjectIdSet::const_iterator it = registered_ids.begin();
+  for (; it != registered_ids.end(); ++it) {
+    if (0 == id_name.compare(it->name())) {
+      // if we find a registered id with the same name, insert a copy of it
+      // into the list of ids we will notify
+      notify_ids.insert(invalidation::ObjectId(it->source(), it->name()));
+    }
+  }
+
+  // build an object state map, and use it to forward the call to
+  // registered clients such as PushMessagingHandler::OnIncomingNotification
+  // as if this came from the server
+  const syncer::ObjectIdStateMap& id_state_map =
+      ObjectIdSetToStateMap(notify_ids, payload);
+  OnIncomingInvalidation(id_state_map, syncer::REMOTE_INVALIDATION);
+}
+
 void ProfileSyncService::Shutdown() {
   ShutdownImpl(false);
 }
 
 void ProfileSyncService::ShutdownImpl(bool sync_disabled) {
   // First, we spin down the backend and wait for it to stop syncing completely
   // before we Stop the data type manager.  This is to avoid a late sync cycle
   // applying changes to the sync db that wouldn't get applied via
   // ChangeProcessors, leading to back-from-the-dead bugs.
   base::Time shutdown_start_time = base::Time::Now();
@@ skipping 1329 matching lines @@
   // See http://stackoverflow.com/questions/6224121/is-new-this-myclass-undefined-behaviour-after-directly-calling-the-destru.
   ProfileSyncService* old_this = this;
   this->~ProfileSyncService();
   new(old_this) ProfileSyncService(
       new ProfileSyncComponentsFactoryImpl(profile,
                                            CommandLine::ForCurrentProcess()),
       profile,
       signin,
       behavior);
 }