attachment broker wip

content/child/npapi/np_channel_base.h

 // Copyright 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.
 
 #ifndef CONTENT_CHILD_NPAPI_NP_CHANNEL_BASE_H_
 #define CONTENT_CHILD_NPAPI_NP_CHANNEL_BASE_H_
 
 #include <string>
 
 #include "base/basictypes.h"
 #include "base/containers/hash_tables.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/process/process.h"
 #include "content/child/npapi/npobject_base.h"
 #include "content/common/message_router.h"
 #include "ipc/ipc_channel_handle.h"
 #include "ipc/ipc_sync_channel.h"
 
 namespace base {
 class SingleThreadTaskRunner;
 }
 
+namespace IPC {
+class AttachmentBroker;
+}
+
 namespace content {
 
 // Encapsulates an IPC channel between a renderer and another process. Used to
 // proxy access to NP objects.
 class NPChannelBase : public IPC::Listener,
                       public IPC::Sender,
                       public base::RefCountedThreadSafe<NPChannelBase> {
  public:
 
   // WebPlugin[Delegate] call these on construction and destruction to setup
@@ skipping 64 matching lines @@
   // If an existing channel exists returns that object, otherwise creates a
   // new one.  Even though on creation the object is refcounted, each caller
   // must still ref count the returned value.  When there are no more routes
   // on the channel and its ref count is 0, the object deletes itself.
   static NPChannelBase* GetChannel(
       const IPC::ChannelHandle& channel_handle,
       IPC::Channel::Mode mode,
       ChannelFactory factory,
       base::SingleThreadTaskRunner* ipc_task_runner,
       bool create_pipe_now,
-      base::WaitableEvent* shutdown_event);
+      base::WaitableEvent* shutdown_event,
+      IPC::AttachmentBroker* broker);
 
   // Sends a message to all instances.
   static void Broadcast(IPC::Message* message);
 
   // Called on the worker thread
   NPChannelBase();
 
   virtual void CleanUp() { }
 
   // Implemented by derived classes to handle control messages
   virtual bool OnControlMessageReceived(const IPC::Message& msg);
 
   // IPC::Listener implementation:
   bool OnMessageReceived(const IPC::Message& msg) override;
   void OnChannelConnected(int32 peer_pid) override;
   void OnChannelError() override;
 
   void set_send_unblocking_only_during_unblock_dispatch() {
     send_unblocking_only_during_unblock_dispatch_ = true;
   }
 
   virtual bool Init(base::SingleThreadTaskRunner* ipc_task_runner,
                     bool create_pipe_now,
-                    base::WaitableEvent* shutdown_event);
+                    base::WaitableEvent* shutdown_event,
+                    IPC::AttachmentBroker* broker);
 
   scoped_ptr<IPC::SyncChannel> channel_;
   IPC::ChannelHandle channel_handle_;
 
  private:
   IPC::Channel::Mode mode_;
   // This tracks the number of routes registered without an NPObject. It's used
   // to manage the lifetime of this object. See comment for AddRoute() and
   // RemoveRoute().
   int non_npobject_count_;
@@ skipping 46 matching lines @@
   // have the unblock flag set, since they could be followed by a sync message
   // that won't get dispatched until the call to the renderer is complete.
   bool send_unblocking_only_during_unblock_dispatch_;
 
   DISALLOW_COPY_AND_ASSIGN(NPChannelBase);
 };
 
 }  // namespace content
 
 #endif  // CONTENT_CHILD_NPAPI_NP_CHANNEL_BASE_H_