Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(6664)

Unified Diff: chrome/renderer/plugin_channel_host.cc

Issue 6713005: Move a bunch of gpu/worker/plugin renderer code to content. I temporarily disabled the sad plugi... (Closed) Base URL: svn://chrome-svn/chrome/trunk/src/
Patch Set: '' Created 9 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « chrome/renderer/plugin_channel_host.h ('k') | chrome/renderer/render_thread.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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();
-}
« no previous file with comments | « chrome/renderer/plugin_channel_host.h ('k') | chrome/renderer/render_thread.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698