[Extensions] Begin making Extension port initialization asynchronous

extensions/renderer/messaging_bindings.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 EXTENSIONS_RENDERER_MESSAGING_BINDINGS_H_
 #define EXTENSIONS_RENDERER_MESSAGING_BINDINGS_H_
 
 #include <string>
 
 #include "base/macros.h"
 #include "base/memory/weak_ptr.h"
 #include "extensions/renderer/object_backed_native_handler.h"
 
 struct ExtensionMsg_ExternalConnectionInfo;
 struct ExtensionMsg_TabConnectionInfo;
 
 namespace content {
 class RenderFrame;
 }
 
 namespace extensions {
+class ExtensionPort;
 struct Message;
 class ScriptContextSet;
 
 // Manually implements JavaScript bindings for extension messaging.
 class MessagingBindings : public ObjectBackedNativeHandler {
  public:
   explicit MessagingBindings(ScriptContext* script_context);
   ~MessagingBindings() override;
 
   // Checks whether the port exists in the given frame. If it does not, a reply
@@ skipping 21 matching lines @@
                              const Message& message,
                              content::RenderFrame* restrict_to_render_frame);
 
   // Dispatches the onDisconnect event in response to the channel being closed.
   static void DispatchOnDisconnect(
       const ScriptContextSet& context_set,
       int port_id,
       const std::string& error_message,
       content::RenderFrame* restrict_to_render_frame);
 
+  // Returns an existing port with the given |global_id|, or null.
+  ExtensionPort* GetPortWithGlobalId(int global_id);
+
+  // Creates a new port with the given |global_id|. MessagingBindings owns the
+  // returned port.
+  ExtensionPort* CreateNewPortWithGlobalId(int global_id);
+
+  // Removes the port with the given |local_id|.
+  void RemovePortWithLocalId(int local_id);
+
+  base::WeakPtr<MessagingBindings> GetWeakPtr();
+
  private:
+  using PortMap = std::map<int, std::unique_ptr<ExtensionPort>>;
+
   // JS Exposed Function: Sends a message along the given channel.
   void PostMessage(const v8::FunctionCallbackInfo<v8::Value>& args);
 
   // JS Exposed Function: Close a port, optionally forcefully (i.e. close the
   // whole channel instead of just the given port).
   void CloseChannel(const v8::FunctionCallbackInfo<v8::Value>& args);
 
   // JS Exposed Function: Binds |callback| to be invoked *sometime after*
   // |object| is garbage collected. We don't call the method re-entrantly so as
   // to avoid executing JS in some bizarro undefined mid-GC state, nor do we
   // then call into the script context if it's been invalidated.
   void BindToGC(const v8::FunctionCallbackInfo<v8::Value>& args);
 
+  // JS Exposed Function: Opens a new channel to an extension.
+  void OpenChannelToExtension(const v8::FunctionCallbackInfo<v8::Value>& args);
+
+  // JS Exposed Function: Opens a new channel to a native application.
+  void OpenChannelToNativeApp(const v8::FunctionCallbackInfo<v8::Value>& args);
+
+  // JS Exposed Function: Opens a new channel to a tab.
+  void OpenChannelToTab(const v8::FunctionCallbackInfo<v8::Value>& args);
+
   // Helper function to close a port. See CloseChannel() for |force_close|
   // documentation.
   void ClosePort(int port_id, bool force_close);
 
+  // Sets the global id for the port with |local_id|.
+  void SetGlobalPortId(int local_id, int global_id);
+
+  int GetNextLocalId();
+
+  // Active ports, mapped by local port id.
+  PortMap ports_;
+
+  // Ports which are disconnected, but haven't been fully initialized. Once
+  // initialized and any pending messages are sent, these ports are removed.
+  PortMap disconnected_ports_;
+
+  // The next available local id for a port.
+  int next_local_id_ = 0;
+
   base::WeakPtrFactory<MessagingBindings> weak_ptr_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(MessagingBindings);
 };
 
 }  // namespace extensions
 
 #endif  // EXTENSIONS_RENDERER_MESSAGING_BINDINGS_H_