Index: chrome/browser/nacl_host/nacl_process_host.cc |
diff --git a/chrome/browser/nacl_host/nacl_process_host.cc b/chrome/browser/nacl_host/nacl_process_host.cc |
deleted file mode 100644 |
index 530ebbb50318b7ab873e46560581e670801946ad..0000000000000000000000000000000000000000 |
--- a/chrome/browser/nacl_host/nacl_process_host.cc |
+++ /dev/null |
@@ -1,1023 +0,0 @@ |
-// Copyright (c) 2012 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/nacl_host/nacl_process_host.h" |
- |
-#include <algorithm> |
-#include <string> |
-#include <vector> |
- |
-#include "base/base_switches.h" |
-#include "base/bind.h" |
-#include "base/command_line.h" |
-#include "base/file_util.h" |
-#include "base/message_loop/message_loop.h" |
-#include "base/metrics/histogram.h" |
-#include "base/path_service.h" |
-#include "base/process/launch.h" |
-#include "base/process/process_iterator.h" |
-#include "base/rand_util.h" |
-#include "base/strings/string_number_conversions.h" |
-#include "base/strings/string_split.h" |
-#include "base/strings/string_util.h" |
-#include "base/strings/stringprintf.h" |
-#include "base/strings/utf_string_conversions.h" |
-#include "base/win/windows_version.h" |
-#include "build/build_config.h" |
-#include "chrome/browser/nacl_host/nacl_host_message_filter.h" |
-#include "chrome/common/chrome_switches.h" |
-#include "components/nacl/browser/nacl_browser.h" |
-#include "components/nacl/common/nacl_cmd_line.h" |
-#include "components/nacl/common/nacl_host_messages.h" |
-#include "components/nacl/common/nacl_messages.h" |
-#include "components/nacl/common/nacl_process_type.h" |
-#include "components/nacl/common/nacl_switches.h" |
-#include "content/public/browser/browser_child_process_host.h" |
-#include "content/public/browser/browser_ppapi_host.h" |
-#include "content/public/browser/child_process_data.h" |
-#include "content/public/common/child_process_host.h" |
-#include "content/public/common/content_switches.h" |
-#include "content/public/common/process_type.h" |
-#include "ipc/ipc_channel.h" |
-#include "ipc/ipc_switches.h" |
-#include "native_client/src/shared/imc/nacl_imc_c.h" |
-#include "net/base/net_util.h" |
-#include "net/socket/tcp_listen_socket.h" |
-#include "ppapi/host/host_factory.h" |
-#include "ppapi/host/ppapi_host.h" |
-#include "ppapi/proxy/ppapi_messages.h" |
-#include "ppapi/shared_impl/ppapi_nacl_channel_args.h" |
- |
-#if defined(OS_POSIX) |
-#include <fcntl.h> |
- |
-#include "ipc/ipc_channel_posix.h" |
-#elif defined(OS_WIN) |
-#include <windows.h> |
- |
-#include "base/threading/thread.h" |
-#include "base/win/scoped_handle.h" |
-#include "chrome/browser/nacl_host/nacl_broker_service_win.h" |
-#include "components/nacl/common/nacl_debug_exception_handler_win.h" |
-#include "content/public/common/sandbox_init.h" |
-#include "content/public/common/sandboxed_process_launcher_delegate.h" |
-#endif |
- |
-using content::BrowserThread; |
-using content::ChildProcessData; |
-using content::ChildProcessHost; |
-using ppapi::proxy::SerializedHandle; |
- |
-#if defined(OS_WIN) |
- |
-namespace { |
- |
-// Looks for the largest contiguous unallocated region of address |
-// space and returns it via |*out_addr| and |*out_size|. |
-void FindAddressSpace(base::ProcessHandle process, |
- char** out_addr, size_t* out_size) { |
- *out_addr = NULL; |
- *out_size = 0; |
- char* addr = 0; |
- while (true) { |
- MEMORY_BASIC_INFORMATION info; |
- size_t result = VirtualQueryEx(process, static_cast<void*>(addr), |
- &info, sizeof(info)); |
- if (result < sizeof(info)) |
- break; |
- if (info.State == MEM_FREE && info.RegionSize > *out_size) { |
- *out_addr = addr; |
- *out_size = info.RegionSize; |
- } |
- addr += info.RegionSize; |
- } |
-} |
- |
-} // namespace |
- |
-namespace nacl { |
- |
-// Allocates |size| bytes of address space in the given process at a |
-// randomised address. |
-void* AllocateAddressSpaceASLR(base::ProcessHandle process, size_t size) { |
- char* addr; |
- size_t avail_size; |
- FindAddressSpace(process, &addr, &avail_size); |
- if (avail_size < size) |
- return NULL; |
- size_t offset = base::RandGenerator(avail_size - size); |
- const int kPageSize = 0x10000; |
- void* request_addr = |
- reinterpret_cast<void*>(reinterpret_cast<uint64>(addr + offset) |
- & ~(kPageSize - 1)); |
- return VirtualAllocEx(process, request_addr, size, |
- MEM_RESERVE, PAGE_NOACCESS); |
-} |
- |
-} // namespace nacl |
- |
-#endif // defined(OS_WIN) |
- |
-namespace { |
- |
-#if defined(OS_WIN) |
-bool RunningOnWOW64() { |
- return (base::win::OSInfo::GetInstance()->wow64_status() == |
- base::win::OSInfo::WOW64_ENABLED); |
-} |
- |
-// NOTE: changes to this class need to be reviewed by the security team. |
-class NaClSandboxedProcessLauncherDelegate |
- : public content::SandboxedProcessLauncherDelegate { |
- public: |
- NaClSandboxedProcessLauncherDelegate() {} |
- virtual ~NaClSandboxedProcessLauncherDelegate() {} |
- |
- virtual void PostSpawnTarget(base::ProcessHandle process) { |
- // For Native Client sel_ldr processes on 32-bit Windows, reserve 1 GB of |
- // address space to prevent later failure due to address space fragmentation |
- // from .dll loading. The NaCl process will attempt to locate this space by |
- // scanning the address space using VirtualQuery. |
- // TODO(bbudge) Handle the --no-sandbox case. |
- // http://code.google.com/p/nativeclient/issues/detail?id=2131 |
- const SIZE_T kNaClSandboxSize = 1 << 30; |
- if (!nacl::AllocateAddressSpaceASLR(process, kNaClSandboxSize)) { |
- DLOG(WARNING) << "Failed to reserve address space for Native Client"; |
- } |
- } |
-}; |
- |
-#endif // OS_WIN |
- |
-void SetCloseOnExec(NaClHandle fd) { |
-#if defined(OS_POSIX) |
- int flags = fcntl(fd, F_GETFD); |
- CHECK_NE(flags, -1); |
- int rc = fcntl(fd, F_SETFD, flags | FD_CLOEXEC); |
- CHECK_EQ(rc, 0); |
-#endif |
-} |
- |
-bool ShareHandleToSelLdr( |
- base::ProcessHandle processh, |
- NaClHandle sourceh, |
- bool close_source, |
- std::vector<nacl::FileDescriptor> *handles_for_sel_ldr) { |
-#if defined(OS_WIN) |
- HANDLE channel; |
- int flags = DUPLICATE_SAME_ACCESS; |
- if (close_source) |
- flags |= DUPLICATE_CLOSE_SOURCE; |
- if (!DuplicateHandle(GetCurrentProcess(), |
- reinterpret_cast<HANDLE>(sourceh), |
- processh, |
- &channel, |
- 0, // Unused given DUPLICATE_SAME_ACCESS. |
- FALSE, |
- flags)) { |
- LOG(ERROR) << "DuplicateHandle() failed"; |
- return false; |
- } |
- handles_for_sel_ldr->push_back( |
- reinterpret_cast<nacl::FileDescriptor>(channel)); |
-#else |
- nacl::FileDescriptor channel; |
- channel.fd = sourceh; |
- channel.auto_close = close_source; |
- handles_for_sel_ldr->push_back(channel); |
-#endif |
- return true; |
-} |
- |
-ppapi::PpapiPermissions GetNaClPermissions(uint32 permission_bits) { |
- // Only allow NaCl plugins to request certain permissions. We don't want |
- // a compromised renderer to be able to start a nacl plugin with e.g. Flash |
- // permissions which may expand the surface area of the sandbox. |
- uint32 masked_bits = permission_bits & ppapi::PERMISSION_DEV; |
- return ppapi::PpapiPermissions::GetForCommandLine(masked_bits); |
-} |
- |
-} // namespace |
- |
-struct NaClProcessHost::NaClInternal { |
- NaClHandle socket_for_renderer; |
- NaClHandle socket_for_sel_ldr; |
- |
- NaClInternal() |
- : socket_for_renderer(NACL_INVALID_HANDLE), |
- socket_for_sel_ldr(NACL_INVALID_HANDLE) { } |
-}; |
- |
-// ----------------------------------------------------------------------------- |
- |
-NaClProcessHost::PluginListener::PluginListener(NaClProcessHost* host) |
- : host_(host) { |
-} |
- |
-bool NaClProcessHost::PluginListener::OnMessageReceived( |
- const IPC::Message& msg) { |
- return host_->OnUntrustedMessageForwarded(msg); |
-} |
- |
-NaClProcessHost::NaClProcessHost(const GURL& manifest_url, |
- int render_view_id, |
- uint32 permission_bits, |
- bool uses_irt, |
- bool enable_dyncode_syscalls, |
- bool enable_exception_handling, |
- bool enable_crash_throttling, |
- bool off_the_record, |
- const base::FilePath& profile_directory) |
- : manifest_url_(manifest_url), |
- permissions_(GetNaClPermissions(permission_bits)), |
-#if defined(OS_WIN) |
- process_launched_by_broker_(false), |
-#endif |
- reply_msg_(NULL), |
-#if defined(OS_WIN) |
- debug_exception_handler_requested_(false), |
-#endif |
- internal_(new NaClInternal()), |
- weak_factory_(this), |
- uses_irt_(uses_irt), |
- enable_debug_stub_(false), |
- enable_dyncode_syscalls_(enable_dyncode_syscalls), |
- enable_exception_handling_(enable_exception_handling), |
- enable_crash_throttling_(enable_crash_throttling), |
- off_the_record_(off_the_record), |
- profile_directory_(profile_directory), |
- ipc_plugin_listener_(this), |
- render_view_id_(render_view_id) { |
- process_.reset(content::BrowserChildProcessHost::Create( |
- PROCESS_TYPE_NACL_LOADER, this)); |
- |
- // Set the display name so the user knows what plugin the process is running. |
- // We aren't on the UI thread so getting the pref locale for language |
- // formatting isn't possible, so IDN will be lost, but this is probably OK |
- // for this use case. |
- process_->SetName(net::FormatUrl(manifest_url_, std::string())); |
- |
- enable_debug_stub_ = CommandLine::ForCurrentProcess()->HasSwitch( |
- switches::kEnableNaClDebug); |
-} |
- |
-NaClProcessHost::~NaClProcessHost() { |
- // Report exit status only if the process was successfully started. |
- if (process_->GetData().handle != base::kNullProcessHandle) { |
- int exit_code = 0; |
- process_->GetTerminationStatus(false /* known_dead */, &exit_code); |
- std::string message = |
- base::StringPrintf("NaCl process exited with status %i (0x%x)", |
- exit_code, exit_code); |
- if (exit_code == 0) { |
- LOG(INFO) << message; |
- } else { |
- LOG(ERROR) << message; |
- } |
- } |
- |
- if (internal_->socket_for_renderer != NACL_INVALID_HANDLE) { |
- if (NaClClose(internal_->socket_for_renderer) != 0) { |
- NOTREACHED() << "NaClClose() failed"; |
- } |
- } |
- |
- if (internal_->socket_for_sel_ldr != NACL_INVALID_HANDLE) { |
- if (NaClClose(internal_->socket_for_sel_ldr) != 0) { |
- NOTREACHED() << "NaClClose() failed"; |
- } |
- } |
- |
- if (reply_msg_) { |
- // The process failed to launch for some reason. |
- // Don't keep the renderer hanging. |
- reply_msg_->set_reply_error(); |
- nacl_host_message_filter_->Send(reply_msg_); |
- } |
-#if defined(OS_WIN) |
- if (process_launched_by_broker_) { |
- NaClBrokerService::GetInstance()->OnLoaderDied(); |
- } |
-#endif |
-} |
- |
-void NaClProcessHost::OnProcessCrashed(int exit_status) { |
- if (enable_crash_throttling_ && |
- !CommandLine::ForCurrentProcess()->HasSwitch( |
- switches::kDisablePnaclCrashThrottling)) { |
- nacl::NaClBrowser::GetInstance()->OnProcessCrashed(); |
- } |
-} |
- |
-// This is called at browser startup. |
-// static |
-void NaClProcessHost::EarlyStartup() { |
- nacl::NaClBrowser::GetInstance()->EarlyStartup(); |
-#if defined(OS_LINUX) && !defined(OS_CHROMEOS) |
- // Open the IRT file early to make sure that it isn't replaced out from |
- // under us by autoupdate. |
- nacl::NaClBrowser::GetInstance()->EnsureIrtAvailable(); |
-#endif |
- CommandLine* cmd = CommandLine::ForCurrentProcess(); |
- UMA_HISTOGRAM_BOOLEAN( |
- "NaCl.nacl-gdb", |
- !cmd->GetSwitchValuePath(switches::kNaClGdb).empty()); |
- UMA_HISTOGRAM_BOOLEAN( |
- "NaCl.nacl-gdb-script", |
- !cmd->GetSwitchValuePath(switches::kNaClGdbScript).empty()); |
- UMA_HISTOGRAM_BOOLEAN( |
- "NaCl.enable-nacl-debug", |
- cmd->HasSwitch(switches::kEnableNaClDebug)); |
- nacl::NaClBrowser::GetDelegate()->SetDebugPatterns( |
- cmd->GetSwitchValueASCII(switches::kNaClDebugMask)); |
-} |
- |
-void NaClProcessHost::Launch( |
- NaClHostMessageFilter* nacl_host_message_filter, |
- IPC::Message* reply_msg, |
- const base::FilePath& manifest_path) { |
- nacl_host_message_filter_ = nacl_host_message_filter; |
- reply_msg_ = reply_msg; |
- manifest_path_ = manifest_path; |
- |
- // Do not launch the requested NaCl module if NaCl is marked "unstable" due |
- // to too many crashes within a given time period. |
- if (enable_crash_throttling_ && |
- !CommandLine::ForCurrentProcess()->HasSwitch( |
- switches::kDisablePnaclCrashThrottling) && |
- nacl::NaClBrowser::GetInstance()->IsThrottled()) { |
- SendErrorToRenderer("Process creation was throttled due to excessive" |
- " crashes"); |
- delete this; |
- return; |
- } |
- |
- const CommandLine* cmd = CommandLine::ForCurrentProcess(); |
-#if defined(OS_WIN) |
- if (cmd->HasSwitch(switches::kEnableNaClDebug) && |
- !cmd->HasSwitch(switches::kNoSandbox)) { |
- // We don't switch off sandbox automatically for security reasons. |
- SendErrorToRenderer("NaCl's GDB debug stub requires --no-sandbox flag" |
- " on Windows. See crbug.com/265624."); |
- delete this; |
- return; |
- } |
-#endif |
- if (cmd->HasSwitch(switches::kNaClGdb) && |
- !cmd->HasSwitch(switches::kEnableNaClDebug)) { |
- LOG(WARNING) << "--nacl-gdb flag requires --enable-nacl-debug flag"; |
- } |
- |
- // Start getting the IRT open asynchronously while we launch the NaCl process. |
- // We'll make sure this actually finished in StartWithLaunchedProcess, below. |
- nacl::NaClBrowser* nacl_browser = nacl::NaClBrowser::GetInstance(); |
- nacl_browser->EnsureAllResourcesAvailable(); |
- if (!nacl_browser->IsOk()) { |
- SendErrorToRenderer("could not find all the resources needed" |
- " to launch the process"); |
- delete this; |
- return; |
- } |
- |
- // Rather than creating a socket pair in the renderer, and passing |
- // one side through the browser to sel_ldr, socket pairs are created |
- // in the browser and then passed to the renderer and sel_ldr. |
- // |
- // This is mainly for the benefit of Windows, where sockets cannot |
- // be passed in messages, but are copied via DuplicateHandle(). |
- // This means the sandboxed renderer cannot send handles to the |
- // browser process. |
- |
- NaClHandle pair[2]; |
- // Create a connected socket |
- if (NaClSocketPair(pair) == -1) { |
- SendErrorToRenderer("NaClSocketPair() failed"); |
- delete this; |
- return; |
- } |
- internal_->socket_for_renderer = pair[0]; |
- internal_->socket_for_sel_ldr = pair[1]; |
- SetCloseOnExec(pair[0]); |
- SetCloseOnExec(pair[1]); |
- |
- // Launch the process |
- if (!LaunchSelLdr()) { |
- delete this; |
- } |
-} |
- |
-void NaClProcessHost::OnChannelConnected(int32 peer_pid) { |
- if (!CommandLine::ForCurrentProcess()->GetSwitchValuePath( |
- switches::kNaClGdb).empty()) { |
- LaunchNaClGdb(); |
- } |
-} |
- |
-#if defined(OS_WIN) |
-void NaClProcessHost::OnProcessLaunchedByBroker(base::ProcessHandle handle) { |
- process_launched_by_broker_ = true; |
- process_->SetHandle(handle); |
- if (!StartWithLaunchedProcess()) |
- delete this; |
-} |
- |
-void NaClProcessHost::OnDebugExceptionHandlerLaunchedByBroker(bool success) { |
- IPC::Message* reply = attach_debug_exception_handler_reply_msg_.release(); |
- NaClProcessMsg_AttachDebugExceptionHandler::WriteReplyParams(reply, success); |
- Send(reply); |
-} |
-#endif |
- |
-// Needed to handle sync messages in OnMessageRecieved. |
-bool NaClProcessHost::Send(IPC::Message* msg) { |
- return process_->Send(msg); |
-} |
- |
-bool NaClProcessHost::LaunchNaClGdb() { |
-#if defined(OS_WIN) |
- base::FilePath nacl_gdb = |
- CommandLine::ForCurrentProcess()->GetSwitchValuePath(switches::kNaClGdb); |
- CommandLine cmd_line(nacl_gdb); |
-#else |
- CommandLine::StringType nacl_gdb = |
- CommandLine::ForCurrentProcess()->GetSwitchValueNative( |
- switches::kNaClGdb); |
- CommandLine::StringVector argv; |
- // We don't support spaces inside arguments in --nacl-gdb switch. |
- base::SplitString(nacl_gdb, static_cast<CommandLine::CharType>(' '), &argv); |
- CommandLine cmd_line(argv); |
-#endif |
- cmd_line.AppendArg("--eval-command"); |
- base::FilePath::StringType irt_path( |
- nacl::NaClBrowser::GetInstance()->GetIrtFilePath().value()); |
- // Avoid back slashes because nacl-gdb uses posix escaping rules on Windows. |
- // See issue https://code.google.com/p/nativeclient/issues/detail?id=3482. |
- std::replace(irt_path.begin(), irt_path.end(), '\\', '/'); |
- cmd_line.AppendArgNative(FILE_PATH_LITERAL("nacl-irt \"") + irt_path + |
- FILE_PATH_LITERAL("\"")); |
- if (!manifest_path_.empty()) { |
- cmd_line.AppendArg("--eval-command"); |
- base::FilePath::StringType manifest_path_value(manifest_path_.value()); |
- std::replace(manifest_path_value.begin(), manifest_path_value.end(), |
- '\\', '/'); |
- cmd_line.AppendArgNative(FILE_PATH_LITERAL("nacl-manifest \"") + |
- manifest_path_value + FILE_PATH_LITERAL("\"")); |
- } |
- cmd_line.AppendArg("--eval-command"); |
- cmd_line.AppendArg("target remote :4014"); |
- base::FilePath script = CommandLine::ForCurrentProcess()->GetSwitchValuePath( |
- switches::kNaClGdbScript); |
- if (!script.empty()) { |
- cmd_line.AppendArg("--command"); |
- cmd_line.AppendArgNative(script.value()); |
- } |
- return base::LaunchProcess(cmd_line, base::LaunchOptions(), NULL); |
-} |
- |
-bool NaClProcessHost::LaunchSelLdr() { |
- std::string channel_id = process_->GetHost()->CreateChannel(); |
- if (channel_id.empty()) { |
- SendErrorToRenderer("CreateChannel() failed"); |
- return false; |
- } |
- |
- CommandLine::StringType nacl_loader_prefix; |
-#if defined(OS_POSIX) |
- nacl_loader_prefix = CommandLine::ForCurrentProcess()->GetSwitchValueNative( |
- switches::kNaClLoaderCmdPrefix); |
-#endif // defined(OS_POSIX) |
- |
- // Build command line for nacl. |
- |
-#if defined(OS_MACOSX) |
- // The Native Client process needs to be able to allocate a 1GB contiguous |
- // region to use as the client environment's virtual address space. ASLR |
- // (PIE) interferes with this by making it possible that no gap large enough |
- // to accomodate this request will exist in the child process' address |
- // space. Disable PIE for NaCl processes. See http://crbug.com/90221 and |
- // http://code.google.com/p/nativeclient/issues/detail?id=2043. |
- int flags = ChildProcessHost::CHILD_NO_PIE; |
-#elif defined(OS_LINUX) |
- int flags = nacl_loader_prefix.empty() ? ChildProcessHost::CHILD_ALLOW_SELF : |
- ChildProcessHost::CHILD_NORMAL; |
-#else |
- int flags = ChildProcessHost::CHILD_NORMAL; |
-#endif |
- |
- base::FilePath exe_path = ChildProcessHost::GetChildPath(flags); |
- if (exe_path.empty()) |
- return false; |
- |
-#if defined(OS_WIN) |
- // On Windows 64-bit NaCl loader is called nacl64.exe instead of chrome.exe |
- if (RunningOnWOW64()) { |
- if (!nacl::NaClBrowser::GetInstance()->GetNaCl64ExePath(&exe_path)) { |
- SendErrorToRenderer("could not get path to nacl64.exe"); |
- return false; |
- } |
- } |
-#endif |
- |
- scoped_ptr<CommandLine> cmd_line(new CommandLine(exe_path)); |
- nacl::CopyNaClCommandLineArguments(cmd_line.get()); |
- |
- cmd_line->AppendSwitchASCII(switches::kProcessType, |
- switches::kNaClLoaderProcess); |
- cmd_line->AppendSwitchASCII(switches::kProcessChannelID, channel_id); |
- if (nacl::NaClBrowser::GetDelegate()->DialogsAreSuppressed()) |
- cmd_line->AppendSwitch(switches::kNoErrorDialogs); |
- |
- if (!nacl_loader_prefix.empty()) |
- cmd_line->PrependWrapper(nacl_loader_prefix); |
- |
- // On Windows we might need to start the broker process to launch a new loader |
-#if defined(OS_WIN) |
- if (RunningOnWOW64()) { |
- if (!NaClBrokerService::GetInstance()->LaunchLoader( |
- weak_factory_.GetWeakPtr(), channel_id)) { |
- SendErrorToRenderer("broker service did not launch process"); |
- return false; |
- } |
- } else { |
- process_->Launch(new NaClSandboxedProcessLauncherDelegate, |
- cmd_line.release()); |
- } |
-#elif defined(OS_POSIX) |
- process_->Launch(nacl_loader_prefix.empty(), // use_zygote |
- base::EnvironmentMap(), |
- cmd_line.release()); |
-#endif |
- |
- return true; |
-} |
- |
-bool NaClProcessHost::OnMessageReceived(const IPC::Message& msg) { |
- bool handled = true; |
- IPC_BEGIN_MESSAGE_MAP(NaClProcessHost, msg) |
- IPC_MESSAGE_HANDLER(NaClProcessMsg_QueryKnownToValidate, |
- OnQueryKnownToValidate) |
- IPC_MESSAGE_HANDLER(NaClProcessMsg_SetKnownToValidate, |
- OnSetKnownToValidate) |
- IPC_MESSAGE_HANDLER_DELAY_REPLY(NaClProcessMsg_ResolveFileToken, |
- OnResolveFileToken) |
-#if defined(OS_WIN) |
- IPC_MESSAGE_HANDLER_DELAY_REPLY(NaClProcessMsg_AttachDebugExceptionHandler, |
- OnAttachDebugExceptionHandler) |
-#endif |
- IPC_MESSAGE_HANDLER(NaClProcessHostMsg_PpapiChannelCreated, |
- OnPpapiChannelCreated) |
- IPC_MESSAGE_UNHANDLED(handled = false) |
- IPC_END_MESSAGE_MAP() |
- return handled; |
-} |
- |
-void NaClProcessHost::OnProcessLaunched() { |
- if (!StartWithLaunchedProcess()) |
- delete this; |
-} |
- |
-// Called when the NaClBrowser singleton has been fully initialized. |
-void NaClProcessHost::OnResourcesReady() { |
- nacl::NaClBrowser* nacl_browser = nacl::NaClBrowser::GetInstance(); |
- if (!nacl_browser->IsReady()) { |
- SendErrorToRenderer("could not acquire shared resources needed by NaCl"); |
- delete this; |
- } else if (!SendStart()) { |
- delete this; |
- } |
-} |
- |
-bool NaClProcessHost::ReplyToRenderer( |
- const IPC::ChannelHandle& channel_handle) { |
-#if defined(OS_WIN) |
- // If we are on 64-bit Windows, the NaCl process's sandbox is |
- // managed by a different process from the renderer's sandbox. We |
- // need to inform the renderer's sandbox about the NaCl process so |
- // that the renderer can send handles to the NaCl process using |
- // BrokerDuplicateHandle(). |
- if (RunningOnWOW64()) { |
- if (!content::BrokerAddTargetPeer(process_->GetData().handle)) { |
- SendErrorToRenderer("BrokerAddTargetPeer() failed"); |
- return false; |
- } |
- } |
-#endif |
- |
- nacl::FileDescriptor handle_for_renderer; |
-#if defined(OS_WIN) |
- // Copy the handle into the renderer process. |
- HANDLE handle_in_renderer; |
- if (!DuplicateHandle(base::GetCurrentProcessHandle(), |
- reinterpret_cast<HANDLE>( |
- internal_->socket_for_renderer), |
- nacl_host_message_filter_->PeerHandle(), |
- &handle_in_renderer, |
- 0, // Unused given DUPLICATE_SAME_ACCESS. |
- FALSE, |
- DUPLICATE_CLOSE_SOURCE | DUPLICATE_SAME_ACCESS)) { |
- SendErrorToRenderer("DuplicateHandle() failed"); |
- return false; |
- } |
- handle_for_renderer = reinterpret_cast<nacl::FileDescriptor>( |
- handle_in_renderer); |
-#else |
- // No need to dup the imc_handle - we don't pass it anywhere else so |
- // it cannot be closed. |
- nacl::FileDescriptor imc_handle; |
- imc_handle.fd = internal_->socket_for_renderer; |
- imc_handle.auto_close = true; |
- handle_for_renderer = imc_handle; |
-#endif |
- |
- const ChildProcessData& data = process_->GetData(); |
- SendMessageToRenderer( |
- nacl::NaClLaunchResult(handle_for_renderer, |
- channel_handle, |
- base::GetProcId(data.handle), |
- data.id), |
- std::string() /* error_message */); |
- internal_->socket_for_renderer = NACL_INVALID_HANDLE; |
- return true; |
-} |
- |
-void NaClProcessHost::SendErrorToRenderer(const std::string& error_message) { |
- LOG(ERROR) << "NaCl process launch failed: " << error_message; |
- SendMessageToRenderer(nacl::NaClLaunchResult(), error_message); |
-} |
- |
-void NaClProcessHost::SendMessageToRenderer( |
- const nacl::NaClLaunchResult& result, |
- const std::string& error_message) { |
- DCHECK(nacl_host_message_filter_); |
- DCHECK(reply_msg_); |
- if (nacl_host_message_filter_ != NULL && reply_msg_ != NULL) { |
- NaClHostMsg_LaunchNaCl::WriteReplyParams( |
- reply_msg_, result, error_message); |
- nacl_host_message_filter_->Send(reply_msg_); |
- nacl_host_message_filter_ = NULL; |
- reply_msg_ = NULL; |
- } |
-} |
- |
-// TCP port we chose for NaCl debug stub. It can be any other number. |
-static const int kDebugStubPort = 4014; |
- |
-#if defined(OS_POSIX) |
-net::SocketDescriptor NaClProcessHost::GetDebugStubSocketHandle() { |
- nacl::NaClBrowser* nacl_browser = nacl::NaClBrowser::GetInstance(); |
- net::SocketDescriptor s = net::kInvalidSocket; |
- // We allocate currently unused TCP port for debug stub tests. The port |
- // number is passed to the test via debug stub port listener. |
- if (nacl_browser->HasGdbDebugStubPortListener()) { |
- int port; |
- s = net::TCPListenSocket::CreateAndBindAnyPort("127.0.0.1", &port); |
- if (s != net::kInvalidSocket) { |
- nacl_browser->FireGdbDebugStubPortOpened(port); |
- } |
- } else { |
- s = net::TCPListenSocket::CreateAndBind("127.0.0.1", kDebugStubPort); |
- } |
- if (s == net::kInvalidSocket) { |
- LOG(ERROR) << "failed to open socket for debug stub"; |
- return net::kInvalidSocket; |
- } |
- if (listen(s, 1)) { |
- LOG(ERROR) << "listen() failed on debug stub socket"; |
- if (HANDLE_EINTR(close(s)) < 0) |
- PLOG(ERROR) << "failed to close debug stub socket"; |
- return net::kInvalidSocket; |
- } |
- return s; |
-} |
-#endif |
- |
-bool NaClProcessHost::StartNaClExecution() { |
- nacl::NaClBrowser* nacl_browser = nacl::NaClBrowser::GetInstance(); |
- |
- nacl::NaClStartParams params; |
- params.validation_cache_enabled = nacl_browser->ValidationCacheIsEnabled(); |
- params.validation_cache_key = nacl_browser->GetValidationCacheKey(); |
- params.version = nacl::NaClBrowser::GetDelegate()->GetVersionString(); |
- params.enable_exception_handling = enable_exception_handling_; |
- params.enable_debug_stub = enable_debug_stub_ && |
- nacl::NaClBrowser::GetDelegate()->URLMatchesDebugPatterns(manifest_url_); |
- // Enable PPAPI proxy channel creation only for renderer processes. |
- params.enable_ipc_proxy = enable_ppapi_proxy(); |
- params.uses_irt = uses_irt_; |
- params.enable_dyncode_syscalls = enable_dyncode_syscalls_; |
- |
- const ChildProcessData& data = process_->GetData(); |
- if (!ShareHandleToSelLdr(data.handle, |
- internal_->socket_for_sel_ldr, true, |
- ¶ms.handles)) { |
- return false; |
- } |
- |
- if (params.uses_irt) { |
- base::PlatformFile irt_file = nacl_browser->IrtFile(); |
- CHECK_NE(irt_file, base::kInvalidPlatformFileValue); |
- // Send over the IRT file handle. We don't close our own copy! |
- if (!ShareHandleToSelLdr(data.handle, irt_file, false, ¶ms.handles)) |
- return false; |
- } |
- |
-#if defined(OS_MACOSX) |
- // For dynamic loading support, NaCl requires a file descriptor that |
- // was created in /tmp, since those created with shm_open() are not |
- // mappable with PROT_EXEC. Rather than requiring an extra IPC |
- // round trip out of the sandbox, we create an FD here. |
- base::SharedMemory memory_buffer; |
- base::SharedMemoryCreateOptions options; |
- options.size = 1; |
- options.executable = true; |
- if (!memory_buffer.Create(options)) { |
- DLOG(ERROR) << "Failed to allocate memory buffer"; |
- return false; |
- } |
- nacl::FileDescriptor memory_fd; |
- memory_fd.fd = dup(memory_buffer.handle().fd); |
- if (memory_fd.fd < 0) { |
- DLOG(ERROR) << "Failed to dup() a file descriptor"; |
- return false; |
- } |
- memory_fd.auto_close = true; |
- params.handles.push_back(memory_fd); |
-#endif |
- |
-#if defined(OS_POSIX) |
- if (params.enable_debug_stub) { |
- net::SocketDescriptor server_bound_socket = GetDebugStubSocketHandle(); |
- if (server_bound_socket != net::kInvalidSocket) { |
- params.debug_stub_server_bound_socket = |
- nacl::FileDescriptor(server_bound_socket, true); |
- } |
- } |
-#endif |
- |
- process_->Send(new NaClProcessMsg_Start(params)); |
- |
- internal_->socket_for_sel_ldr = NACL_INVALID_HANDLE; |
- return true; |
-} |
- |
-bool NaClProcessHost::SendStart() { |
- if (!enable_ppapi_proxy()) { |
- if (!ReplyToRenderer(IPC::ChannelHandle())) |
- return false; |
- } |
- return StartNaClExecution(); |
-} |
- |
-// This method is called when NaClProcessHostMsg_PpapiChannelCreated is |
-// received or PpapiHostMsg_ChannelCreated is forwarded by our plugin |
-// listener. |
-void NaClProcessHost::OnPpapiChannelCreated( |
- const IPC::ChannelHandle& channel_handle) { |
- // Only renderer processes should create a channel. |
- DCHECK(enable_ppapi_proxy()); |
- // If the proxy channel is null, this must be the initial NaCl-Browser IPC |
- // channel. |
- if (!ipc_proxy_channel_.get()) { |
- DCHECK_EQ(PROCESS_TYPE_NACL_LOADER, process_->GetData().process_type); |
- |
- ipc_proxy_channel_.reset( |
- new IPC::ChannelProxy(channel_handle, |
- IPC::Channel::MODE_CLIENT, |
- &ipc_plugin_listener_, |
- base::MessageLoopProxy::current().get())); |
- // Create the browser ppapi host and enable PPAPI message dispatching to the |
- // browser process. |
- ppapi_host_.reset(content::BrowserPpapiHost::CreateExternalPluginProcess( |
- ipc_proxy_channel_.get(), // sender |
- permissions_, |
- process_->GetData().handle, |
- ipc_proxy_channel_.get(), |
- nacl_host_message_filter_->render_process_id(), |
- render_view_id_, |
- profile_directory_)); |
- |
- ppapi::PpapiNaClChannelArgs args; |
- args.off_the_record = nacl_host_message_filter_->off_the_record(); |
- args.permissions = permissions_; |
- CommandLine* cmdline = CommandLine::ForCurrentProcess(); |
- DCHECK(cmdline); |
- std::string flag_whitelist[] = {switches::kV, switches::kVModule}; |
- for (size_t i = 0; i < arraysize(flag_whitelist); ++i) { |
- std::string value = cmdline->GetSwitchValueASCII(flag_whitelist[i]); |
- if (!value.empty()) { |
- args.switch_names.push_back(flag_whitelist[i]); |
- args.switch_values.push_back(value); |
- } |
- } |
- |
- ppapi_host_->GetPpapiHost()->AddHostFactoryFilter( |
- scoped_ptr<ppapi::host::HostFactory>( |
- nacl::NaClBrowser::GetDelegate()->CreatePpapiHostFactory( |
- ppapi_host_.get()))); |
- |
- // Send a message to create the NaCl-Renderer channel. The handle is just |
- // a place holder. |
- ipc_proxy_channel_->Send( |
- new PpapiMsg_CreateNaClChannel( |
- nacl_host_message_filter_->render_process_id(), |
- args, |
- SerializedHandle(SerializedHandle::CHANNEL_HANDLE, |
- IPC::InvalidPlatformFileForTransit()))); |
- } else if (reply_msg_) { |
- // Otherwise, this must be a renderer channel. |
- ReplyToRenderer(channel_handle); |
- } else { |
- // Attempt to open more than 1 renderer channel is not supported. |
- // Shut down the NaCl process. |
- process_->GetHost()->ForceShutdown(); |
- } |
-} |
- |
-bool NaClProcessHost::OnUntrustedMessageForwarded(const IPC::Message& msg) { |
- // Handle messages that have been forwarded from our PluginListener. |
- // These messages come from untrusted code so should be handled with care. |
- bool handled = true; |
- IPC_BEGIN_MESSAGE_MAP(NaClProcessHost, msg) |
- IPC_MESSAGE_HANDLER(PpapiHostMsg_ChannelCreated, |
- OnPpapiChannelCreated) |
- IPC_MESSAGE_UNHANDLED(handled = false) |
- IPC_END_MESSAGE_MAP() |
- return handled; |
-} |
- |
-bool NaClProcessHost::StartWithLaunchedProcess() { |
- nacl::NaClBrowser* nacl_browser = nacl::NaClBrowser::GetInstance(); |
- |
- if (nacl_browser->IsReady()) { |
- return SendStart(); |
- } else if (nacl_browser->IsOk()) { |
- nacl_browser->WaitForResources( |
- base::Bind(&NaClProcessHost::OnResourcesReady, |
- weak_factory_.GetWeakPtr())); |
- return true; |
- } else { |
- SendErrorToRenderer("previously failed to acquire shared resources"); |
- return false; |
- } |
-} |
- |
-void NaClProcessHost::OnQueryKnownToValidate(const std::string& signature, |
- bool* result) { |
- nacl::NaClBrowser* nacl_browser = nacl::NaClBrowser::GetInstance(); |
- *result = nacl_browser->QueryKnownToValidate(signature, off_the_record_); |
-} |
- |
-void NaClProcessHost::OnSetKnownToValidate(const std::string& signature) { |
- nacl::NaClBrowser::GetInstance()->SetKnownToValidate( |
- signature, off_the_record_); |
-} |
- |
-void NaClProcessHost::FileResolved( |
- base::PlatformFile* file, |
- const base::FilePath& file_path, |
- IPC::Message* reply_msg) { |
- if (*file != base::kInvalidPlatformFileValue) { |
- IPC::PlatformFileForTransit handle = IPC::GetFileHandleForProcess( |
- *file, |
- process_->GetData().handle, |
- true /* close_source */); |
- NaClProcessMsg_ResolveFileToken::WriteReplyParams( |
- reply_msg, |
- handle, |
- file_path); |
- } else { |
- NaClProcessMsg_ResolveFileToken::WriteReplyParams( |
- reply_msg, |
- IPC::InvalidPlatformFileForTransit(), |
- base::FilePath(FILE_PATH_LITERAL(""))); |
- } |
- Send(reply_msg); |
-} |
- |
-void NaClProcessHost::OnResolveFileToken(uint64 file_token_lo, |
- uint64 file_token_hi, |
- IPC::Message* reply_msg) { |
- // Was the file registered? |
- // |
- // Note that the file path cache is of bounded size, and old entries can get |
- // evicted. If a large number of NaCl modules are being launched at once, |
- // resolving the file_token may fail because the path cache was thrashed |
- // while the file_token was in flight. In this case the query fails, and we |
- // need to fall back to the slower path. |
- // |
- // However: each NaCl process will consume 2-3 entries as it starts up, this |
- // means that eviction will not happen unless you start up 33+ NaCl processes |
- // at the same time, and this still requires worst-case timing. As a |
- // practical matter, no entries should be evicted prematurely. |
- // The cache itself should take ~ (150 characters * 2 bytes/char + ~60 bytes |
- // data structure overhead) * 100 = 35k when full, so making it bigger should |
- // not be a problem, if needed. |
- // |
- // Each NaCl process will consume 2-3 entries because the manifest and main |
- // nexe are currently not resolved. Shared libraries will be resolved. They |
- // will be loaded sequentially, so they will only consume a single entry |
- // while the load is in flight. |
- // |
- // TODO(ncbray): track behavior with UMA. If entries are getting evicted or |
- // bogus keys are getting queried, this would be good to know. |
- base::FilePath file_path; |
- if (!nacl::NaClBrowser::GetInstance()->GetFilePath( |
- file_token_lo, file_token_hi, &file_path)) { |
- NaClProcessMsg_ResolveFileToken::WriteReplyParams( |
- reply_msg, |
- IPC::InvalidPlatformFileForTransit(), |
- base::FilePath(FILE_PATH_LITERAL(""))); |
- Send(reply_msg); |
- return; |
- } |
- |
- // Scratch space to share between the callbacks. |
- base::PlatformFile* data = new base::PlatformFile(); |
- |
- // Open the file. |
- if (!content::BrowserThread::PostBlockingPoolTaskAndReply( |
- FROM_HERE, |
- base::Bind(nacl::OpenNaClExecutableImpl, |
- file_path, data), |
- base::Bind(&NaClProcessHost::FileResolved, |
- weak_factory_.GetWeakPtr(), |
- base::Owned(data), |
- file_path, |
- reply_msg))) { |
- NaClProcessMsg_ResolveFileToken::WriteReplyParams( |
- reply_msg, |
- IPC::InvalidPlatformFileForTransit(), |
- base::FilePath(FILE_PATH_LITERAL(""))); |
- Send(reply_msg); |
- } |
-} |
- |
-#if defined(OS_WIN) |
-void NaClProcessHost::OnAttachDebugExceptionHandler(const std::string& info, |
- IPC::Message* reply_msg) { |
- if (!AttachDebugExceptionHandler(info, reply_msg)) { |
- // Send failure message. |
- NaClProcessMsg_AttachDebugExceptionHandler::WriteReplyParams(reply_msg, |
- false); |
- Send(reply_msg); |
- } |
-} |
- |
-bool NaClProcessHost::AttachDebugExceptionHandler(const std::string& info, |
- IPC::Message* reply_msg) { |
- if (!enable_exception_handling_ && !enable_debug_stub_) { |
- DLOG(ERROR) << |
- "Debug exception handler requested by NaCl process when not enabled"; |
- return false; |
- } |
- if (debug_exception_handler_requested_) { |
- // The NaCl process should not request this multiple times. |
- DLOG(ERROR) << "Multiple AttachDebugExceptionHandler requests received"; |
- return false; |
- } |
- debug_exception_handler_requested_ = true; |
- |
- base::ProcessId nacl_pid = base::GetProcId(process_->GetData().handle); |
- base::win::ScopedHandle process_handle; |
- // We cannot use process_->GetData().handle because it does not have |
- // the necessary access rights. We open the new handle here rather |
- // than in the NaCl broker process in case the NaCl loader process |
- // dies before the NaCl broker process receives the message we send. |
- // The debug exception handler uses DebugActiveProcess() to attach, |
- // but this takes a PID. We need to prevent the NaCl loader's PID |
- // from being reused before DebugActiveProcess() is called, and |
- // holding a process handle open achieves this. |
- if (!base::OpenProcessHandleWithAccess( |
- nacl_pid, |
- base::kProcessAccessQueryInformation | |
- base::kProcessAccessSuspendResume | |
- base::kProcessAccessTerminate | |
- base::kProcessAccessVMOperation | |
- base::kProcessAccessVMRead | |
- base::kProcessAccessVMWrite | |
- base::kProcessAccessDuplicateHandle | |
- base::kProcessAccessWaitForTermination, |
- process_handle.Receive())) { |
- LOG(ERROR) << "Failed to get process handle"; |
- return false; |
- } |
- |
- attach_debug_exception_handler_reply_msg_.reset(reply_msg); |
- // If the NaCl loader is 64-bit, the process running its debug |
- // exception handler must be 64-bit too, so we use the 64-bit NaCl |
- // broker process for this. Otherwise, on a 32-bit system, we use |
- // the 32-bit browser process to run the debug exception handler. |
- if (RunningOnWOW64()) { |
- return NaClBrokerService::GetInstance()->LaunchDebugExceptionHandler( |
- weak_factory_.GetWeakPtr(), nacl_pid, process_handle, info); |
- } else { |
- NaClStartDebugExceptionHandlerThread( |
- process_handle.Take(), info, |
- base::MessageLoopProxy::current(), |
- base::Bind(&NaClProcessHost::OnDebugExceptionHandlerLaunchedByBroker, |
- weak_factory_.GetWeakPtr())); |
- return true; |
- } |
-} |
-#endif |