Index: chrome/renderer/plugin_channel_host.cc |
=================================================================== |
--- chrome/renderer/plugin_channel_host.cc (revision 78516) |
+++ chrome/renderer/plugin_channel_host.cc (working copy) |
@@ -1,145 +0,0 @@ |
-// Copyright (c) 2010 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 "chrome/renderer/plugin_channel_host.h" |
- |
-#include "content/common/plugin_messages.h" |
-#include "content/plugin/npobject_base.h" |
- |
-#if defined(OS_POSIX) |
-#include "ipc/ipc_channel_posix.h" |
-#endif |
- |
-#include "third_party/WebKit/Source/WebKit/chromium/public/WebBindings.h" |
- |
-// A simple MessageFilter that will ignore all messages and respond to sync |
-// messages with an error when is_listening_ is false. |
-class IsListeningFilter : public IPC::ChannelProxy::MessageFilter { |
- public: |
- IsListeningFilter() : channel_(NULL) {} |
- |
- // MessageFilter overrides |
- virtual void OnFilterRemoved() {} |
- virtual void OnFilterAdded(IPC::Channel* channel) { channel_ = channel; } |
- virtual bool OnMessageReceived(const IPC::Message& message); |
- |
- static bool is_listening_; |
- |
- private: |
- IPC::Channel* channel_; |
- |
- DISALLOW_COPY_AND_ASSIGN(IsListeningFilter); |
-}; |
- |
-bool IsListeningFilter::OnMessageReceived(const IPC::Message& message) { |
- if (IsListeningFilter::is_listening_) { |
- // Proceed with normal operation. |
- return false; |
- } |
- |
- // Always process message reply to prevent renderer from hanging on sync |
- // messages. |
- if (message.is_reply() || message.is_reply_error()) { |
- return false; |
- } |
- |
- // Reply to synchronous messages with an error (so they don't block while |
- // we're not listening). |
- if (message.is_sync()) { |
- IPC::Message* reply = IPC::SyncMessage::GenerateReply(&message); |
- reply->set_reply_error(); |
- channel_->Send(reply); |
- } |
- return true; |
-} |
- |
-// static |
-bool IsListeningFilter::is_listening_ = true; |
- |
-// static |
-bool PluginChannelHost::IsListening() { |
- return IsListeningFilter::is_listening_; |
-} |
- |
-// static |
-void PluginChannelHost::SetListening(bool flag) { |
- IsListeningFilter::is_listening_ = flag; |
-} |
- |
-PluginChannelHost* PluginChannelHost::GetPluginChannelHost( |
- const IPC::ChannelHandle& channel_handle, MessageLoop* ipc_message_loop) { |
- PluginChannelHost* result = |
- static_cast<PluginChannelHost*>(PluginChannelBase::GetChannel( |
- channel_handle, |
- IPC::Channel::MODE_CLIENT, |
- ClassFactory, |
- ipc_message_loop, |
- true)); |
- return result; |
-} |
- |
-PluginChannelHost::PluginChannelHost() : expecting_shutdown_(false) { |
-} |
- |
-PluginChannelHost::~PluginChannelHost() { |
-} |
- |
-bool PluginChannelHost::Init(MessageLoop* ipc_message_loop, |
- bool create_pipe_now) { |
- bool ret = PluginChannelBase::Init(ipc_message_loop, create_pipe_now); |
- is_listening_filter_ = new IsListeningFilter; |
- channel_->AddFilter(is_listening_filter_); |
- return ret; |
-} |
- |
-int PluginChannelHost::GenerateRouteID() { |
- int route_id = MSG_ROUTING_NONE; |
- Send(new PluginMsg_GenerateRouteID(&route_id)); |
- |
- return route_id; |
-} |
- |
-void PluginChannelHost::AddRoute(int route_id, |
- IPC::Channel::Listener* listener, |
- NPObjectBase* npobject) { |
- PluginChannelBase::AddRoute(route_id, listener, npobject); |
- |
- if (!npobject) |
- proxies_[route_id] = listener; |
-} |
- |
-void PluginChannelHost::RemoveRoute(int route_id) { |
- proxies_.erase(route_id); |
- PluginChannelBase::RemoveRoute(route_id); |
-} |
- |
-bool PluginChannelHost::OnControlMessageReceived(const IPC::Message& message) { |
- bool handled = true; |
- IPC_BEGIN_MESSAGE_MAP(PluginChannelHost, message) |
- IPC_MESSAGE_HANDLER(PluginHostMsg_SetException, OnSetException) |
- IPC_MESSAGE_HANDLER(PluginHostMsg_PluginShuttingDown, OnPluginShuttingDown) |
- IPC_MESSAGE_UNHANDLED(handled = false) |
- IPC_END_MESSAGE_MAP() |
- DCHECK(handled); |
- return handled; |
-} |
- |
-void PluginChannelHost::OnSetException(const std::string& message) { |
- WebKit::WebBindings::setException(NULL, message.c_str()); |
-} |
- |
-void PluginChannelHost::OnPluginShuttingDown(const IPC::Message& message) { |
- expecting_shutdown_ = true; |
-} |
- |
-void PluginChannelHost::OnChannelError() { |
- PluginChannelBase::OnChannelError(); |
- |
- for (ProxyMap::iterator iter = proxies_.begin(); |
- iter != proxies_.end(); iter++) { |
- iter->second->OnChannelError(); |
- } |
- |
- proxies_.clear(); |
-} |