Commit InvalidationService implementations

chrome/browser/invalidation/p2p_invalidation_service.h

Index: chrome/browser/invalidation/p2p_invalidation_service.h
diff --git a/chrome/browser/invalidation/p2p_invalidation_service.h b/chrome/browser/invalidation/p2p_invalidation_service.h
new file mode 100644
index 0000000000000000000000000000000000000000..4827f5c3d4c6de46bd4ab128ba9c984132765ed5
--- /dev/null
+++ b/chrome/browser/invalidation/p2p_invalidation_service.h
@@ -0,0 +1,64 @@
+// Copyright (c) 2013 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 "base/threading/non_thread_safe.h"
+#include "chrome/browser/invalidation/invalidation_frontend.h"
+#include "chrome/browser/profiles/profile_keyed_service.h"
+#include "sync/notifier/object_id_invalidation_map.h"
+
+#ifndef CHROME_BROWSER_INVALIDATION_P2P_INVALIDATION_SERVICE_H_
+#define CHROME_BROWSER_INVALIDATION_P2P_INVALIDATION_SERVICE_H_
+
+namespace syncer {
+class P2PInvalidator;
+}
+
+class Profile;
+
+namespace invalidation {
+
+// This service is a wrapper around P2PInvalidator.  Unlike other
+// InvalidationServices, it can both send and receive invalidations.  It is used
+// only in tests, where we're unable to connect to a real invalidations server.
+class P2PInvalidationService
+    : public base::NonThreadSafe,
+      public ProfileKeyedService,
+      public InvalidationFrontend {
+ public:
+  P2PInvalidationService();
+  virtual ~P2PInvalidationService();
+
+  // Overrides ProfileKeyedService method.
+  virtual void Shutdown() OVERRIDE;
+
+  // InvalidationFrontend implementation.
+  // It is an error to have registered handlers when Shutdown() is called.
+  virtual void RegisterInvalidationHandler(
+      syncer::InvalidationHandler* handler) OVERRIDE;
+  virtual void UpdateRegisteredInvalidationIds(
+      syncer::InvalidationHandler* handler,
+      const syncer::ObjectIdSet& ids) OVERRIDE;
+  virtual void UnregisterInvalidationHandler(
+      syncer::InvalidationHandler* handler) OVERRIDE;
+  virtual void AcknowledgeInvalidation(
+      const invalidation::ObjectId& id,
+      const syncer::AckHandle& ack_handle) OVERRIDE;
+  virtual syncer::InvalidatorState GetInvalidatorState() const OVERRIDE;
+  virtual std::string GetInvalidatorClientId() const;
+
+  void Init(Profile* profile);
+  void UpdateCredentials(const std::string& username,
+                         const std::string& password);
+
+  virtual void SendInvalidation(
+      const syncer::ObjectIdInvalidationMap& invalidation_map);

[dcheng, 2013/05/03 18:07:34]

Does this need to be virtual? I don't think InvalidationFrontend has this in the
interface, so I'm curious where it's coming from.

[rlarocque, 2013/05/03 22:16:14]

You might be right.  SendInvalidation() used to be part of the Invalidator's
interface.  I must have forgot to update the signature when I copied and pasted
it.

+
+ private:
+  scoped_ptr<syncer::P2PInvalidator> invalidator_;
+  std::string invalidator_id_;

[tim (not reviewing), 2013/05/03 17:48:23]

DISALLOW_COPY_AND_ASSIGN

[rlarocque, 2013/05/03 22:16:14]

Done.

+};
+
+}  // namespace invalidation
+
+#endif  // CHROME_BROWSER_INVALIDATION_P2P_INVALIDATION_SERVICE_H_