Refactor navigator.connect code to make it more flexible.

content/public/browser/navigator_connect_context.h

 // 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.
 
-#ifndef CONTENT_RENDERER_QUEUE_MESSAGE_SWAP_PROMISE_H_
-#define CONTENT_RENDERER_QUEUE_MESSAGE_SWAP_PROMISE_H_
+#ifndef CONTENT_PUBLIC_BROWSER_NAVIGATOR_CONNECT_CONTEXT_H_
+#define CONTENT_PUBLIC_BROWSER_NAVIGATOR_CONNECT_CONTEXT_H_
 
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
-#include "cc/base/swap_promise.h"
-
-namespace IPC {
-class SyncMessageFilter;
-}
 
 namespace content {
 
-class FrameSwapMessageQueue;
+class NavigatorConnectServiceFactory;
 
-class QueueMessageSwapPromise : public cc::SwapPromise {
+// Use this class to register additional navigator.connect service factories.
+// The most recently added factory that claims to handle a URL will be used to

[scheib, 2015/01/23 22:03:58]

Move the AddFactory doc to the method.

[Marijn Kruisselbrink, 2015/01/26 21:34:26]

Done.

+// handle a connection request for that URL.
+// One instance of this class exists per StoragePartition.
+// TODO(mek): Add API to this class so NavigatorConnectService implementations
+// can send messages back to the client.
+// TODO(mek): Add API so services can close a connection.
+class NavigatorConnectContext
+    : public base::RefCountedThreadSafe<NavigatorConnectContext> {
  public:
-  QueueMessageSwapPromise(scoped_refptr<IPC::SyncMessageFilter> message_sender,
-                          scoped_refptr<FrameSwapMessageQueue> message_queue,
-                          int source_frame_number);
+  virtual void AddFactory(
+      scoped_ptr<NavigatorConnectServiceFactory> factory) = 0;
 
-  ~QueueMessageSwapPromise() override;
-
-  void DidSwap(cc::CompositorFrameMetadata* metadata) override;
-
-  void DidNotSwap(DidNotSwapReason reason) override;
-
-  int64 TraceId() const override;
-
- private:
-  void PromiseCompleted();
-
-  scoped_refptr<IPC::SyncMessageFilter> message_sender_;
-  scoped_refptr<content::FrameSwapMessageQueue> message_queue_;
-  int source_frame_number_;
-#if DCHECK_IS_ON()
-  bool completed_;
-#endif
+ protected:
+  friend class base::RefCountedThreadSafe<NavigatorConnectContext>;
+  NavigatorConnectContext() {}
+  virtual ~NavigatorConnectContext() {}
 };
 
 }  // namespace content
 
-#endif  // CONTENT_RENDERER_QUEUE_MESSAGE_SWAP_PROMISE_H_
+#endif  // CONTENT_PUBLIC_BROWSER_NAVIGATOR_CONNECT_CONTEXT_H_