| Index: chrome/browser/ppapi_plugin_process_host.cc
|
| ===================================================================
|
| --- chrome/browser/ppapi_plugin_process_host.cc (revision 75653)
|
| +++ chrome/browser/ppapi_plugin_process_host.cc (working copy)
|
| @@ -1,174 +0,0 @@
|
| -// Copyright (c) 2011 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/browser/ppapi_plugin_process_host.h"
|
| -
|
| -#include "base/command_line.h"
|
| -#include "base/file_path.h"
|
| -#include "base/process_util.h"
|
| -#include "chrome/browser/plugin_service.h"
|
| -#include "chrome/browser/renderer_host/render_message_filter.h"
|
| -#include "chrome/common/chrome_switches.h"
|
| -#include "chrome/common/render_messages.h"
|
| -#include "ipc/ipc_switches.h"
|
| -#include "ppapi/proxy/ppapi_messages.h"
|
| -
|
| -PpapiPluginProcessHost::PpapiPluginProcessHost()
|
| - : BrowserChildProcessHost(
|
| - ChildProcessInfo::PPAPI_PLUGIN_PROCESS,
|
| - PluginService::GetInstance()->resource_dispatcher_host()) {
|
| -}
|
| -
|
| -PpapiPluginProcessHost::~PpapiPluginProcessHost() {
|
| - CancelRequests();
|
| -}
|
| -
|
| -bool PpapiPluginProcessHost::Init(const FilePath& path) {
|
| - plugin_path_ = path;
|
| -
|
| - if (!CreateChannel())
|
| - return false;
|
| -
|
| - const CommandLine& browser_command_line = *CommandLine::ForCurrentProcess();
|
| - CommandLine::StringType plugin_launcher =
|
| - browser_command_line.GetSwitchValueNative(switches::kPpapiPluginLauncher);
|
| -
|
| - FilePath exe_path = ChildProcessHost::GetChildPath(plugin_launcher.empty());
|
| - if (exe_path.empty())
|
| - return false;
|
| -
|
| - CommandLine* cmd_line = new CommandLine(exe_path);
|
| - cmd_line->AppendSwitchASCII(switches::kProcessType,
|
| - switches::kPpapiPluginProcess);
|
| - cmd_line->AppendSwitchASCII(switches::kProcessChannelID, channel_id());
|
| -
|
| - if (!plugin_launcher.empty())
|
| - cmd_line->PrependWrapper(plugin_launcher);
|
| -
|
| - // On posix, having a plugin launcher means we need to use another process
|
| - // instead of just forking the zygote.
|
| - Launch(
|
| -#if defined(OS_WIN)
|
| - FilePath(),
|
| -#elif defined(OS_POSIX)
|
| - plugin_launcher.empty(),
|
| - base::environment_vector(),
|
| -#endif
|
| - cmd_line);
|
| - return true;
|
| -}
|
| -
|
| -void PpapiPluginProcessHost::OpenChannelToPlugin(Client* client) {
|
| - if (opening_channel()) {
|
| - // The channel is already in the process of being opened. Put
|
| - // this "open channel" request into a queue of requests that will
|
| - // be run once the channel is open.
|
| - pending_requests_.push_back(client);
|
| - return;
|
| - }
|
| -
|
| - // We already have an open channel, send a request right away to plugin.
|
| - RequestPluginChannel(client);
|
| -}
|
| -
|
| -void PpapiPluginProcessHost::RequestPluginChannel(Client* client) {
|
| - base::ProcessHandle process_handle;
|
| - int renderer_id;
|
| - client->GetChannelInfo(&process_handle, &renderer_id);
|
| -
|
| - // We can't send any sync messages from the browser because it might lead to
|
| - // a hang. See the similar code in PluginProcessHost for more description.
|
| - PpapiMsg_CreateChannel* msg = new PpapiMsg_CreateChannel(process_handle,
|
| - renderer_id);
|
| - msg->set_unblock(true);
|
| - if (Send(msg))
|
| - sent_requests_.push(client);
|
| - else
|
| - client->OnChannelOpened(base::kNullProcessHandle, IPC::ChannelHandle());
|
| -}
|
| -
|
| -bool PpapiPluginProcessHost::CanShutdown() {
|
| - return true;
|
| -}
|
| -
|
| -void PpapiPluginProcessHost::OnProcessLaunched() {
|
| -}
|
| -
|
| -bool PpapiPluginProcessHost::OnMessageReceived(const IPC::Message& msg) {
|
| - bool handled = true;
|
| - IPC_BEGIN_MESSAGE_MAP(PpapiPluginProcessHost, msg)
|
| - IPC_MESSAGE_HANDLER(PpapiHostMsg_ChannelCreated,
|
| - OnRendererPluginChannelCreated)
|
| - IPC_MESSAGE_UNHANDLED(handled = false)
|
| - IPC_END_MESSAGE_MAP()
|
| - DCHECK(handled);
|
| - return handled;
|
| -}
|
| -
|
| -// Called when the browser <--> plugin channel has been established.
|
| -void PpapiPluginProcessHost::OnChannelConnected(int32 peer_pid) {
|
| - // This will actually load the plugin. Errors will actually not be reported
|
| - // back at this point. Instead, the plugin will fail to establish the
|
| - // connections when we request them on behalf of the renderer(s).
|
| - Send(new PpapiMsg_LoadPlugin(plugin_path_));
|
| -
|
| - // Process all pending channel requests from the renderers.
|
| - for (size_t i = 0; i < pending_requests_.size(); i++)
|
| - RequestPluginChannel(pending_requests_[i]);
|
| - pending_requests_.clear();
|
| -}
|
| -
|
| -// Called when the browser <--> plugin channel has an error. This normally
|
| -// means the plugin has crashed.
|
| -void PpapiPluginProcessHost::OnChannelError() {
|
| - // We don't need to notify the renderers that were communicating with the
|
| - // plugin since they have their own channels which will go into the error
|
| - // state at the same time. Instead, we just need to notify any renderers
|
| - // that have requested a connection but have not yet received one.
|
| - CancelRequests();
|
| -}
|
| -
|
| -void PpapiPluginProcessHost::CancelRequests() {
|
| - for (size_t i = 0; i < pending_requests_.size(); i++) {
|
| - pending_requests_[i]->OnChannelOpened(base::kNullProcessHandle,
|
| - IPC::ChannelHandle());
|
| - }
|
| - pending_requests_.clear();
|
| -
|
| - while (!sent_requests_.empty()) {
|
| - sent_requests_.front()->OnChannelOpened(base::kNullProcessHandle,
|
| - IPC::ChannelHandle());
|
| - sent_requests_.pop();
|
| - }
|
| -}
|
| -
|
| -// Called when a new plugin <--> renderer channel has been created.
|
| -void PpapiPluginProcessHost::OnRendererPluginChannelCreated(
|
| - const IPC::ChannelHandle& channel_handle) {
|
| - if (sent_requests_.empty())
|
| - return;
|
| -
|
| - // All requests should be processed FIFO, so the next item in the
|
| - // sent_requests_ queue should be the one that the plugin just created.
|
| - Client* client = sent_requests_.front();
|
| - sent_requests_.pop();
|
| -
|
| - // Prepare the handle to send to the renderer.
|
| - base::ProcessHandle plugin_process = GetChildProcessHandle();
|
| -#if defined(OS_WIN)
|
| - base::ProcessHandle renderer_process;
|
| - int renderer_id;
|
| - client->GetChannelInfo(&renderer_process, &renderer_id);
|
| -
|
| - base::ProcessHandle renderers_plugin_handle = NULL;
|
| - ::DuplicateHandle(::GetCurrentProcess(), plugin_process,
|
| - renderer_process, &renderers_plugin_handle,
|
| - 0, FALSE, DUPLICATE_SAME_ACCESS);
|
| -#elif defined(OS_POSIX)
|
| - // Don't need to duplicate anything on POSIX since it's just a PID.
|
| - base::ProcessHandle renderers_plugin_handle = plugin_process;
|
| -#endif
|
| -
|
| - client->OnChannelOpened(renderers_plugin_handle, channel_handle);
|
| -}
|
|
|