| 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();
|
| -}
|
|
|