| Index: chrome/browser/plugin_process_host.cc
|
| ===================================================================
|
| --- chrome/browser/plugin_process_host.cc (revision 75653)
|
| +++ chrome/browser/plugin_process_host.cc (working copy)
|
| @@ -1,478 +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/plugin_process_host.h"
|
| -
|
| -#if defined(OS_WIN)
|
| -#include <windows.h>
|
| -#elif defined(OS_POSIX)
|
| -#include <utility> // for pair<>
|
| -#endif
|
| -
|
| -#include <vector>
|
| -
|
| -#include "app/app_switches.h"
|
| -#include "base/command_line.h"
|
| -#include "base/file_path.h"
|
| -#include "base/file_util.h"
|
| -#include "base/logging.h"
|
| -#include "base/path_service.h"
|
| -#include "base/string_util.h"
|
| -#include "base/utf_string_conversions.h"
|
| -#include "chrome/browser/browser_thread.h"
|
| -#include "chrome/browser/child_process_security_policy.h"
|
| -#include "chrome/browser/chrome_plugin_browsing_context.h"
|
| -#include "chrome/browser/net/url_request_tracking.h"
|
| -#include "chrome/browser/plugin_download_helper.h"
|
| -#include "chrome/browser/plugin_service.h"
|
| -#include "chrome/browser/profiles/profile.h"
|
| -#include "chrome/browser/renderer_host/resource_dispatcher_host.h"
|
| -#include "chrome/browser/renderer_host/resource_message_filter.h"
|
| -#include "chrome/common/chrome_paths.h"
|
| -#include "chrome/common/chrome_plugin_lib.h"
|
| -#include "chrome/common/chrome_switches.h"
|
| -#include "chrome/common/logging_chrome.h"
|
| -#include "chrome/common/net/url_request_context_getter.h"
|
| -#include "chrome/common/plugin_messages.h"
|
| -#include "chrome/common/render_messages.h"
|
| -#include "chrome/common/render_messages_params.h"
|
| -#include "ipc/ipc_switches.h"
|
| -#include "net/base/cookie_store.h"
|
| -#include "net/base/io_buffer.h"
|
| -#include "net/url_request/url_request.h"
|
| -#include "net/url_request/url_request_context.h"
|
| -#include "ui/base/ui_base_switches.h"
|
| -#include "ui/gfx/native_widget_types.h"
|
| -
|
| -#if defined(USE_X11)
|
| -#include "ui/gfx/gtk_native_view_id_manager.h"
|
| -#endif
|
| -
|
| -#if defined(OS_MACOSX)
|
| -#include "base/mac/mac_util.h"
|
| -#include "chrome/common/plugin_carbon_interpose_constants_mac.h"
|
| -#include "ui/gfx/rect.h"
|
| -#endif
|
| -
|
| -static const char kDefaultPluginFinderURL[] =
|
| - "https://dl-ssl.google.com/edgedl/chrome/plugins/plugins2.xml";
|
| -
|
| -namespace {
|
| -
|
| -// Helper class that we pass to ResourceMessageFilter so that it can find the
|
| -// right net::URLRequestContext for a request.
|
| -class PluginURLRequestContextOverride
|
| - : public ResourceMessageFilter::URLRequestContextOverride {
|
| - public:
|
| - PluginURLRequestContextOverride() {
|
| - }
|
| -
|
| - virtual net::URLRequestContext* GetRequestContext(
|
| - const ViewHostMsg_Resource_Request& resource_request) {
|
| - return CPBrowsingContextManager::GetInstance()->ToURLRequestContext(
|
| - resource_request.request_context);
|
| - }
|
| -
|
| - private:
|
| - virtual ~PluginURLRequestContextOverride() {}
|
| -};
|
| -
|
| -} // namespace
|
| -
|
| -#if defined(OS_WIN)
|
| -void PluginProcessHost::OnPluginWindowDestroyed(HWND window, HWND parent) {
|
| - // The window is destroyed at this point, we just care about its parent, which
|
| - // is the intermediate window we created.
|
| - std::set<HWND>::iterator window_index =
|
| - plugin_parent_windows_set_.find(parent);
|
| - if (window_index == plugin_parent_windows_set_.end())
|
| - return;
|
| -
|
| - plugin_parent_windows_set_.erase(window_index);
|
| - PostMessage(parent, WM_CLOSE, 0, 0);
|
| -}
|
| -
|
| -void PluginProcessHost::OnDownloadUrl(const std::string& url,
|
| - int source_pid,
|
| - gfx::NativeWindow caller_window) {
|
| - PluginDownloadUrlHelper* download_url_helper =
|
| - new PluginDownloadUrlHelper(url, source_pid, caller_window, NULL);
|
| - download_url_helper->InitiateDownload(
|
| - Profile::GetDefaultRequestContext()->GetURLRequestContext());
|
| -}
|
| -
|
| -void PluginProcessHost::AddWindow(HWND window) {
|
| - plugin_parent_windows_set_.insert(window);
|
| -}
|
| -
|
| -#endif // defined(OS_WIN)
|
| -
|
| -#if defined(TOOLKIT_USES_GTK)
|
| -void PluginProcessHost::OnMapNativeViewId(gfx::NativeViewId id,
|
| - gfx::PluginWindowHandle* output) {
|
| - *output = 0;
|
| - GtkNativeViewManager::GetInstance()->GetXIDForId(output, id);
|
| -}
|
| -#endif // defined(TOOLKIT_USES_GTK)
|
| -
|
| -PluginProcessHost::PluginProcessHost()
|
| - : BrowserChildProcessHost(
|
| - PLUGIN_PROCESS,
|
| - PluginService::GetInstance()->resource_dispatcher_host(),
|
| - new PluginURLRequestContextOverride()),
|
| - ALLOW_THIS_IN_INITIALIZER_LIST(resolve_proxy_msg_helper_(this, NULL))
|
| -#if defined(OS_MACOSX)
|
| - , plugin_cursor_visible_(true)
|
| -#endif
|
| -{
|
| -}
|
| -
|
| -PluginProcessHost::~PluginProcessHost() {
|
| -#if defined(OS_WIN)
|
| - // We erase HWNDs from the plugin_parent_windows_set_ when we receive a
|
| - // notification that the window is being destroyed. If we don't receive this
|
| - // notification and the PluginProcessHost instance is being destroyed, it
|
| - // means that the plugin process crashed. We paint a sad face in this case in
|
| - // the renderer process. To ensure that the sad face shows up, and we don't
|
| - // leak HWNDs, we should destroy existing plugin parent windows.
|
| - std::set<HWND>::iterator window_index;
|
| - for (window_index = plugin_parent_windows_set_.begin();
|
| - window_index != plugin_parent_windows_set_.end();
|
| - window_index++) {
|
| - PostMessage(*window_index, WM_CLOSE, 0, 0);
|
| - }
|
| -#elif defined(OS_MACOSX)
|
| - // If the plugin process crashed but had fullscreen windows open at the time,
|
| - // make sure that the menu bar is visible.
|
| - std::set<uint32>::iterator window_index;
|
| - for (window_index = plugin_fullscreen_windows_set_.begin();
|
| - window_index != plugin_fullscreen_windows_set_.end();
|
| - window_index++) {
|
| - if (BrowserThread::CurrentlyOn(BrowserThread::UI)) {
|
| - base::mac::ReleaseFullScreen(base::mac::kFullScreenModeHideAll);
|
| - } else {
|
| - BrowserThread::PostTask(
|
| - BrowserThread::UI, FROM_HERE,
|
| - NewRunnableFunction(base::mac::ReleaseFullScreen,
|
| - base::mac::kFullScreenModeHideAll));
|
| - }
|
| - }
|
| - // If the plugin hid the cursor, reset that.
|
| - if (!plugin_cursor_visible_) {
|
| - if (BrowserThread::CurrentlyOn(BrowserThread::UI)) {
|
| - base::mac::SetCursorVisibility(true);
|
| - } else {
|
| - BrowserThread::PostTask(
|
| - BrowserThread::UI, FROM_HERE,
|
| - NewRunnableFunction(base::mac::SetCursorVisibility,
|
| - true));
|
| - }
|
| - }
|
| -#endif
|
| - // Cancel all pending and sent requests.
|
| - CancelRequests();
|
| -}
|
| -
|
| -bool PluginProcessHost::Init(const webkit::npapi::WebPluginInfo& info,
|
| - const std::string& locale) {
|
| - info_ = info;
|
| - set_name(UTF16ToWideHack(info_.name));
|
| - set_version(UTF16ToWideHack(info_.version));
|
| -
|
| - if (!CreateChannel())
|
| - return false;
|
| -
|
| - // Build command line for plugin. When we have a plugin launcher, we can't
|
| - // allow "self" on linux and we need the real file path.
|
| - const CommandLine& browser_command_line = *CommandLine::ForCurrentProcess();
|
| - CommandLine::StringType plugin_launcher =
|
| - browser_command_line.GetSwitchValueNative(switches::kPluginLauncher);
|
| - FilePath exe_path = GetChildPath(plugin_launcher.empty());
|
| - if (exe_path.empty())
|
| - return false;
|
| -
|
| - CommandLine* cmd_line = new CommandLine(exe_path);
|
| - // Put the process type and plugin path first so they're easier to see
|
| - // in process listings using native process management tools.
|
| - cmd_line->AppendSwitchASCII(switches::kProcessType, switches::kPluginProcess);
|
| - cmd_line->AppendSwitchPath(switches::kPluginPath, info.path);
|
| -
|
| - if (logging::DialogsAreSuppressed())
|
| - cmd_line->AppendSwitch(switches::kNoErrorDialogs);
|
| -
|
| - // Propagate the following switches to the plugin command line (along with
|
| - // any associated values) if present in the browser command line
|
| - static const char* const kSwitchNames[] = {
|
| - switches::kPluginStartupDialog,
|
| - switches::kNoSandbox,
|
| - switches::kSafePlugins,
|
| - switches::kTestSandbox,
|
| - switches::kUserAgent,
|
| - switches::kDisableBreakpad,
|
| - switches::kFullMemoryCrashReport,
|
| - switches::kEnableLogging,
|
| - switches::kDisableLogging,
|
| - switches::kLoggingLevel,
|
| - switches::kLogPluginMessages,
|
| - switches::kUserDataDir,
|
| - switches::kEnableDCHECK,
|
| - switches::kSilentDumpOnDCHECK,
|
| - switches::kMemoryProfiling,
|
| - switches::kUseLowFragHeapCrt,
|
| - switches::kEnableStatsTable,
|
| - switches::kEnableGPUPlugin,
|
| - switches::kUseGL,
|
| -#if defined(OS_CHROMEOS)
|
| - switches::kLoginProfile,
|
| -#endif
|
| - };
|
| -
|
| - cmd_line->CopySwitchesFrom(browser_command_line, kSwitchNames,
|
| - arraysize(kSwitchNames));
|
| -
|
| - // If specified, prepend a launcher program to the command line.
|
| - if (!plugin_launcher.empty())
|
| - cmd_line->PrependWrapper(plugin_launcher);
|
| -
|
| - if (!locale.empty()) {
|
| - // Pass on the locale so the null plugin will use the right language in the
|
| - // prompt to install the desired plugin.
|
| - cmd_line->AppendSwitchASCII(switches::kLang, locale);
|
| - }
|
| -
|
| - // Gears requires the data dir to be available on startup.
|
| - FilePath data_dir =
|
| - PluginService::GetInstance()->GetChromePluginDataDir();
|
| - DCHECK(!data_dir.empty());
|
| - cmd_line->AppendSwitchPath(switches::kPluginDataDir, data_dir);
|
| -
|
| - cmd_line->AppendSwitchASCII(switches::kProcessChannelID, channel_id());
|
| -
|
| - SetCrashReporterCommandLine(cmd_line);
|
| -
|
| -#if defined(OS_POSIX)
|
| - base::environment_vector env;
|
| -#if defined(OS_MACOSX) && !defined(__LP64__)
|
| - // Add our interposing library for Carbon. This is stripped back out in
|
| - // plugin_main.cc, so changes here should be reflected there.
|
| - std::string interpose_list(plugin_interpose_strings::kInterposeLibraryPath);
|
| - const char* existing_list =
|
| - getenv(plugin_interpose_strings::kDYLDInsertLibrariesKey);
|
| - if (existing_list) {
|
| - interpose_list.insert(0, ":");
|
| - interpose_list.insert(0, existing_list);
|
| - }
|
| - env.push_back(std::pair<std::string, std::string>(
|
| - plugin_interpose_strings::kDYLDInsertLibrariesKey,
|
| - interpose_list));
|
| -#endif
|
| -#endif
|
| -
|
| - Launch(
|
| -#if defined(OS_WIN)
|
| - FilePath(),
|
| -#elif defined(OS_POSIX)
|
| - false,
|
| - env,
|
| -#endif
|
| - cmd_line);
|
| -
|
| - return true;
|
| -}
|
| -
|
| -void PluginProcessHost::ForceShutdown() {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| - Send(new PluginProcessMsg_NotifyRenderersOfPendingShutdown());
|
| - BrowserChildProcessHost::ForceShutdown();
|
| -}
|
| -
|
| -void PluginProcessHost::OnProcessLaunched() {
|
| - FilePath gears_path;
|
| - if (PathService::Get(chrome::FILE_GEARS_PLUGIN, &gears_path)) {
|
| - FilePath::StringType gears_path_lc = StringToLowerASCII(gears_path.value());
|
| - FilePath::StringType plugin_path_lc =
|
| - StringToLowerASCII(info_.path.value());
|
| - if (plugin_path_lc == gears_path_lc) {
|
| - // Give Gears plugins "background" priority. See http://b/1280317.
|
| - SetProcessBackgrounded();
|
| - }
|
| - }
|
| -}
|
| -
|
| -bool PluginProcessHost::OnMessageReceived(const IPC::Message& msg) {
|
| - bool handled = true;
|
| - IPC_BEGIN_MESSAGE_MAP(PluginProcessHost, msg)
|
| - IPC_MESSAGE_HANDLER(PluginProcessHostMsg_ChannelCreated, OnChannelCreated)
|
| - IPC_MESSAGE_HANDLER(PluginProcessHostMsg_GetPluginFinderUrl,
|
| - OnGetPluginFinderUrl)
|
| - IPC_MESSAGE_HANDLER(PluginProcessHostMsg_PluginMessage, OnPluginMessage)
|
| - IPC_MESSAGE_HANDLER(PluginProcessHostMsg_GetCookies, OnGetCookies)
|
| - IPC_MESSAGE_HANDLER(PluginProcessHostMsg_AccessFiles, OnAccessFiles)
|
| - IPC_MESSAGE_HANDLER_DELAY_REPLY(PluginProcessHostMsg_ResolveProxy,
|
| - OnResolveProxy)
|
| -#if defined(OS_WIN)
|
| - IPC_MESSAGE_HANDLER(PluginProcessHostMsg_PluginWindowDestroyed,
|
| - OnPluginWindowDestroyed)
|
| - IPC_MESSAGE_HANDLER(PluginProcessHostMsg_DownloadUrl, OnDownloadUrl)
|
| -#endif
|
| -#if defined(TOOLKIT_USES_GTK)
|
| - IPC_MESSAGE_HANDLER(PluginProcessHostMsg_MapNativeViewId,
|
| - OnMapNativeViewId)
|
| -#endif
|
| -#if defined(OS_MACOSX)
|
| - IPC_MESSAGE_HANDLER(PluginProcessHostMsg_PluginSelectWindow,
|
| - OnPluginSelectWindow)
|
| - IPC_MESSAGE_HANDLER(PluginProcessHostMsg_PluginShowWindow,
|
| - OnPluginShowWindow)
|
| - IPC_MESSAGE_HANDLER(PluginProcessHostMsg_PluginHideWindow,
|
| - OnPluginHideWindow)
|
| - IPC_MESSAGE_HANDLER(PluginProcessHostMsg_PluginSetCursorVisibility,
|
| - OnPluginSetCursorVisibility)
|
| -#endif
|
| - IPC_MESSAGE_UNHANDLED(handled = false)
|
| - IPC_END_MESSAGE_MAP()
|
| -
|
| - DCHECK(handled);
|
| - return handled;
|
| -}
|
| -
|
| -void PluginProcessHost::OnChannelConnected(int32 peer_pid) {
|
| - for (size_t i = 0; i < pending_requests_.size(); ++i) {
|
| - RequestPluginChannel(pending_requests_[i]);
|
| - }
|
| -
|
| - pending_requests_.clear();
|
| -}
|
| -
|
| -void PluginProcessHost::OnChannelError() {
|
| - CancelRequests();
|
| -}
|
| -
|
| -bool PluginProcessHost::CanShutdown() {
|
| - return sent_requests_.empty();
|
| -}
|
| -
|
| -void PluginProcessHost::CancelRequests() {
|
| - for (size_t i = 0; i < pending_requests_.size(); ++i)
|
| - pending_requests_[i]->OnError();
|
| - pending_requests_.clear();
|
| -
|
| - while (!sent_requests_.empty()) {
|
| - sent_requests_.front()->OnError();
|
| - sent_requests_.pop();
|
| - }
|
| -}
|
| -
|
| -void PluginProcessHost::OpenChannelToPlugin(Client* client) {
|
| - InstanceCreated();
|
| - client->SetPluginInfo(info_);
|
| - 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 PluginProcessHost::OnGetCookies(uint32 request_context,
|
| - const GURL& url,
|
| - std::string* cookies) {
|
| - net::URLRequestContext* context = CPBrowsingContextManager::GetInstance()->
|
| - ToURLRequestContext(request_context);
|
| - // TODO(mpcomplete): remove fallback case when Gears support is prevalent.
|
| - if (!context)
|
| - context = Profile::GetDefaultRequestContext()->GetURLRequestContext();
|
| -
|
| - // Note: We don't have a first_party_for_cookies check because plugins bypass
|
| - // third-party cookie blocking.
|
| - if (context && context->cookie_store()) {
|
| - *cookies = context->cookie_store()->GetCookies(url);
|
| - } else {
|
| - DLOG(ERROR) << "Could not serve plugin cookies request.";
|
| - cookies->clear();
|
| - }
|
| -}
|
| -
|
| -void PluginProcessHost::OnAccessFiles(int renderer_id,
|
| - const std::vector<std::string>& files,
|
| - bool* allowed) {
|
| - ChildProcessSecurityPolicy* policy =
|
| - ChildProcessSecurityPolicy::GetInstance();
|
| -
|
| - for (size_t i = 0; i < files.size(); ++i) {
|
| - const FilePath path = FilePath::FromWStringHack(UTF8ToWide(files[i]));
|
| - if (!policy->CanReadFile(renderer_id, path)) {
|
| - VLOG(1) << "Denied unauthorized request for file " << files[i];
|
| - *allowed = false;
|
| - return;
|
| - }
|
| - }
|
| -
|
| - *allowed = true;
|
| -}
|
| -
|
| -void PluginProcessHost::OnResolveProxy(const GURL& url,
|
| - IPC::Message* reply_msg) {
|
| - resolve_proxy_msg_helper_.Start(url, reply_msg);
|
| -}
|
| -
|
| -void PluginProcessHost::OnResolveProxyCompleted(IPC::Message* reply_msg,
|
| - int result,
|
| - const std::string& proxy_list) {
|
| - PluginProcessHostMsg_ResolveProxy::WriteReplyParams(
|
| - reply_msg, result, proxy_list);
|
| - Send(reply_msg);
|
| -}
|
| -
|
| -void PluginProcessHost::RequestPluginChannel(Client* client) {
|
| - // We can't send any sync messages from the browser because it might lead to
|
| - // a hang. However this async messages must be answered right away by the
|
| - // plugin process (i.e. unblocks a Send() call like a sync message) otherwise
|
| - // a deadlock can occur if the plugin creation request from the renderer is
|
| - // a result of a sync message by the plugin process.
|
| - PluginProcessMsg_CreateChannel* msg =
|
| - new PluginProcessMsg_CreateChannel(client->ID(),
|
| - client->OffTheRecord());
|
| - msg->set_unblock(true);
|
| - if (Send(msg)) {
|
| - sent_requests_.push(client);
|
| - } else {
|
| - client->OnError();
|
| - }
|
| -}
|
| -
|
| -void PluginProcessHost::OnChannelCreated(
|
| - const IPC::ChannelHandle& channel_handle) {
|
| - Client* client = sent_requests_.front();
|
| -
|
| - client->OnChannelOpened(channel_handle);
|
| - sent_requests_.pop();
|
| -}
|
| -
|
| -void PluginProcessHost::OnGetPluginFinderUrl(std::string* plugin_finder_url) {
|
| - if (!plugin_finder_url) {
|
| - NOTREACHED();
|
| - return;
|
| - }
|
| -
|
| - // TODO(iyengar) Add the plumbing to retrieve the default
|
| - // plugin finder URL.
|
| - *plugin_finder_url = kDefaultPluginFinderURL;
|
| -}
|
| -
|
| -void PluginProcessHost::OnPluginMessage(
|
| - const std::vector<uint8>& data) {
|
| - DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
|
| -
|
| - ChromePluginLib *chrome_plugin = ChromePluginLib::Find(info_.path);
|
| - if (chrome_plugin) {
|
| - void *data_ptr = const_cast<void*>(reinterpret_cast<const void*>(&data[0]));
|
| - uint32 data_len = static_cast<uint32>(data.size());
|
| - chrome_plugin->functions().on_message(data_ptr, data_len);
|
| - }
|
| -}
|
|
|