Index: content/common/np_channel_base.h |
diff --git a/content/common/np_channel_base.h b/content/common/np_channel_base.h |
deleted file mode 100644 |
index f307e9f7d24d90c22282e89437b0188c22670d89..0000000000000000000000000000000000000000 |
--- a/content/common/np_channel_base.h |
+++ /dev/null |
@@ -1,203 +0,0 @@ |
-// 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. |
- |
-#ifndef CONTENT_COMMON_NP_CHANNEL_BASE_H_ |
-#define CONTENT_COMMON_NP_CHANNEL_BASE_H_ |
- |
-#include <string> |
- |
-#include "base/basictypes.h" |
-#include "base/hash_tables.h" |
-#include "base/memory/ref_counted.h" |
-#include "base/memory/scoped_ptr.h" |
-#include "base/process.h" |
-#include "content/common/message_router.h" |
-#include "content/common/npobject_base.h" |
-#include "ipc/ipc_channel_handle.h" |
-#include "ipc/ipc_sync_channel.h" |
- |
-namespace base { |
-class MessageLoopProxy; |
-} |
- |
-#if defined(COMPILER_GCC) |
-namespace BASE_HASH_NAMESPACE { |
- |
-template<> |
-struct hash<NPObject*> { |
- std::size_t operator()(NPObject* const& ptr) const { |
- return hash<size_t>()(reinterpret_cast<size_t>(ptr)); |
- } |
-}; |
- |
-} // namespace __gnu_cxx |
-#elif defined(COMPILER_MSVC) |
-namespace stdext { |
- |
-template<> |
-inline size_t hash_value(NPObject* const& ptr) { |
- return hash_value(reinterpret_cast<size_t>(ptr)); |
-} |
- |
-} // namespace stdext |
-#endif // COMPILER |
- |
-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 |
- // the routing and manage lifetime of this object (they pass NULL for |
- // npobject). These are also called by NPObjectProxy and NPObjectStub (which |
- // pass themselves for npobject). However the latter don't control the |
- // lifetime of this object because we don't want a leak of an NPObject to |
- // keep the channel around longer than necessary. |
- void AddRoute(int route_id, IPC::Listener* listener, NPObjectBase* npobject); |
- void RemoveRoute(int route_id); |
- |
- |
- void AddMappingForNPObjectProxy(int route_id, NPObject* object); |
- void RemoveMappingForNPObjectProxy(int route_id); |
- |
- void AddMappingForNPObjectStub(int route_id, NPObject* object); |
- void RemoveMappingForNPObjectStub(int route_id, NPObject* object); |
- |
- NPObject* GetExistingNPObjectProxy(int route_id); |
- int GetExistingRouteForNPObjectStub(NPObject* npobject); |
- |
- |
- // IPC::Sender implementation: |
- virtual bool Send(IPC::Message* msg) OVERRIDE; |
- |
- base::ProcessId peer_pid() { return channel_->peer_pid(); } |
- IPC::ChannelHandle channel_handle() const { return channel_handle_; } |
- |
- // Returns the number of open NPObject channels in this process. |
- static int Count(); |
- |
- // Returns a new route id. |
- virtual int GenerateRouteID() = 0; |
- |
- // Returns whether the channel is valid or not. A channel is invalid |
- // if it is disconnected due to a channel error. |
- bool channel_valid() { |
- return channel_valid_; |
- } |
- |
- // Returns the most recent NPChannelBase to have received a message |
- // in this process. |
- static NPChannelBase* GetCurrentChannel(); |
- |
- static void CleanupChannels(); |
- |
- // Returns the NPObjectBase object for the route id passed in. |
- // Returns NULL on failure. |
- NPObjectBase* GetNPObjectListenerForRoute(int route_id); |
- |
- // Returns the event that's set when a call to the renderer causes a modal |
- // dialog to come up. The default implementation returns NULL. Derived |
- // classes should override this method if this functionality is required. |
- virtual base::WaitableEvent* GetModalDialogEvent(int render_view_id); |
- |
- protected: |
- typedef NPChannelBase* (*ChannelFactory)(); |
- |
- friend class base::RefCountedThreadSafe<NPChannelBase>; |
- |
- virtual ~NPChannelBase(); |
- |
- // Returns a NPChannelBase derived object for the given channel name. |
- // 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::MessageLoopProxy* ipc_message_loop, |
- bool create_pipe_now, base::WaitableEvent* shutdown_event); |
- |
- // 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: |
- virtual bool OnMessageReceived(const IPC::Message& msg) OVERRIDE; |
- virtual void OnChannelConnected(int32 peer_pid) OVERRIDE; |
- virtual void OnChannelError() OVERRIDE; |
- |
- void set_send_unblocking_only_during_unblock_dispatch() { |
- send_unblocking_only_during_unblock_dispatch_ = true; |
- } |
- |
- virtual bool Init(base::MessageLoopProxy* ipc_message_loop, |
- bool create_pipe_now, |
- base::WaitableEvent* shutdown_event); |
- |
- 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_; |
- int peer_pid_; |
- |
- // true when in the middle of a RemoveRoute call |
- bool in_remove_route_; |
- |
- // Keep track of all the registered NPObjects proxies/stubs so that when the |
- // channel is closed we can inform them. |
- typedef base::hash_map<int, NPObjectBase*> ListenerMap; |
- ListenerMap npobject_listeners_; |
- |
- typedef base::hash_map<int, NPObject*> ProxyMap; |
- ProxyMap proxy_map_; |
- |
- typedef base::hash_map<NPObject*, int> StubMap; |
- StubMap stub_map_; |
- |
- // Used to implement message routing functionality to WebPlugin[Delegate] |
- // objects |
- MessageRouter router_; |
- |
- // A channel is invalid if it is disconnected as a result of a channel |
- // error. This flag is used to indicate the same. |
- bool channel_valid_; |
- |
- // Track whether we're dispatching a message with the unblock flag; works like |
- // a refcount, 0 when we're not. |
- int in_unblock_dispatch_; |
- |
- // If true, sync messages will only be marked as unblocking if the channel is |
- // in the middle of dispatching an unblocking message. The non-renderer |
- // process wants to avoid setting the unblock flag on its sync messages |
- // unless necessary, since it can potentially introduce reentrancy into |
- // WebKit in ways that it doesn't expect (i.e. causing layout during paint). |
- // However to avoid deadlock, we must ensure that any message that's sent as |
- // a result of a sync call from the renderer must unblock the renderer. We |
- // additionally have to do this for async messages from the renderer that |
- // 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_COMMON_NP_CHANNEL_BASE_H_ |