Convert NaCl renderer-browser messages to mojo.

components/nacl/renderer/ppb_nacl_private_impl.cc

 // Copyright 2013 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 "components/nacl/renderer/ppb_nacl_private.h"
 
 #include <stddef.h>
 #include <stdint.h>
 
 #include <memory>
@@ skipping 12 matching lines @@
 #include "base/lazy_instance.h"
 #include "base/location.h"
 #include "base/logging.h"
 #include "base/macros.h"
 #include "base/process/process_handle.h"
 #include "base/single_thread_task_runner.h"
 #include "base/strings/string_split.h"
 #include "base/strings/string_util.h"
 #include "base/threading/thread_task_runner_handle.h"
 #include "build/build_config.h"
-#include "components/nacl/common/nacl_host_messages.h"
-#include "components/nacl/common/nacl_messages.h"
+#include "components/nacl/common/nacl.mojom.h"
 #include "components/nacl/common/nacl_nonsfi_util.h"
 #include "components/nacl/common/nacl_switches.h"
 #include "components/nacl/common/nacl_types.h"
 #include "components/nacl/renderer/file_downloader.h"
 #include "components/nacl/renderer/histogram.h"
 #include "components/nacl/renderer/json_manifest.h"
 #include "components/nacl/renderer/manifest_downloader.h"
 #include "components/nacl/renderer/manifest_service_channel.h"
 #include "components/nacl/renderer/nexe_load_manager.h"
 #include "components/nacl/renderer/platform_info.h"
@@ skipping 10 matching lines @@
 #include "net/base/net_errors.h"
 #include "net/http/http_util.h"
 #include "ppapi/c/pp_bool.h"
 #include "ppapi/c/private/pp_file_handle.h"
 #include "ppapi/shared_impl/ppapi_globals.h"
 #include "ppapi/shared_impl/ppapi_permissions.h"
 #include "ppapi/shared_impl/ppapi_preferences.h"
 #include "ppapi/shared_impl/var.h"
 #include "ppapi/shared_impl/var_tracker.h"
 #include "ppapi/thunk/enter.h"
+#include "services/service_manager/public/cpp/interface_provider.h"
 #include "third_party/WebKit/public/platform/WebSecurityOrigin.h"
 #include "third_party/WebKit/public/platform/WebURLRequest.h"
 #include "third_party/WebKit/public/platform/WebURLResponse.h"
 #include "third_party/WebKit/public/web/WebAssociatedURLLoader.h"
 #include "third_party/WebKit/public/web/WebAssociatedURLLoaderClient.h"
 #include "third_party/WebKit/public/web/WebDocument.h"
 #include "third_party/WebKit/public/web/WebLocalFrame.h"
 #include "third_party/WebKit/public/web/WebPluginContainer.h"
 
 #if defined(OS_WIN)
 #include "base/win/scoped_handle.h"
 #endif
 
 namespace nacl {
 namespace {
 
 // The pseudo-architecture used to indicate portable native client.
 const char* const kPortableArch = "portable";
 
 // The base URL for resources used by the PNaCl translator processes.
 const char* kPNaClTranslatorBaseUrl = "chrome://pnacl-translator/";
 
-base::LazyInstance<scoped_refptr<PnaclTranslationResourceHost> >
+base::LazyInstance<std::unique_ptr<PnaclTranslationResourceHost>>
     g_pnacl_resource_host = LAZY_INSTANCE_INITIALIZER;
 
+class NaClHostConnectionHolder {
+ public:
+  NaClHostConnectionHolder() {
+    content::RenderThread::Get()->GetRemoteInterfaces()->GetInterface(&host_);
+  }
+
+  mojom::NaClHost* host() { return host_.get(); }
+
+ private:
+  mojom::NaClHostPtr host_;
+};
+
+// A renderer-process-wide connection to the browser side. PPBNaClPrivate is a
+// collection of static methods so a global is required to store a persistent
+// connection.
+base::LazyInstance<NaClHostConnectionHolder>::Leaky g_nacl_host_connection =
+    LAZY_INSTANCE_INITIALIZER;
+
 bool InitializePnaclResourceHost() {
   // Must run on the main thread.
   content::RenderThread* render_thread = content::RenderThread::Get();
   if (!render_thread)
     return false;
-  if (!g_pnacl_resource_host.Get().get()) {
+  if (!g_pnacl_resource_host.Get()) {
     g_pnacl_resource_host.Get() =
-        new PnaclTranslationResourceHost(render_thread->GetIOTaskRunner());
-    render_thread->AddFilter(g_pnacl_resource_host.Get().get());
+        base::MakeUnique<PnaclTranslationResourceHost>(
+            g_nacl_host_connection.Get().host());
   }
   return true;
 }
 
 bool CanOpenViaFastPath(content::PepperPluginInstance* plugin_instance,
                         const GURL& gurl) {
   // Fast path only works for installed file URLs.
   if (!gurl.SchemeIs("chrome-extension"))
     return PP_kInvalidFileHandle;
 
@@ skipping 13 matching lines @@
   GURL url;
   ppapi::PpapiPermissions permissions;
   base::ProcessId plugin_pid;
   int plugin_child_id;
   IPC::ChannelHandle channel_handle;
 };
 
 class NaClPluginInstance {
  public:
   explicit NaClPluginInstance(PP_Instance instance)
-      : nexe_load_manager(instance), pexe_size(0) {}
+      : nexe_load_manager(instance, g_nacl_host_connection.Get().host()),
+        pexe_size(0) {}
   ~NaClPluginInstance() {
     // Make sure that we do not leak a mojo handle if the NaCl loader
     // process never called ppapi_start() to initialize PPAPI.
     if (instance_info) {
       DCHECK(instance_info->channel_handle.is_mojo_channel_handle());
       instance_info->channel_handle.mojo_handle.Close();
     }
   }
 
   NexeLoadManager nexe_load_manager;
@@ skipping 251 matching lines @@
     PP_Instance instance,
     PP_Bool main_service_runtime,
     const char* alleged_url,
     const PP_NaClFileInfo* nexe_file_info,
     PP_Bool uses_nonsfi_mode,
     PP_NaClAppProcessType pp_process_type,
     std::unique_ptr<IPC::SyncChannel>* translator_channel,
     PP_CompletionCallback callback) {
   CHECK(ppapi::PpapiGlobals::Get()->GetMainThreadMessageLoop()->
             BelongsToCurrentThread());
+  base::File nexe_file(nexe_file_info->handle);
   NaClAppProcessType process_type = PP_ToNaClAppProcessType(pp_process_type);
   // Create the manifest service proxy here, so on error case, it will be
   // destructed (without passing it to ManifestServiceChannel).
   std::unique_ptr<ManifestServiceChannel::Delegate> manifest_service_proxy(
       new ManifestServiceProxy(instance, process_type));
 
-  IPC::Sender* sender = content::RenderThread::Get();
-  DCHECK(sender);
   int routing_id = GetRoutingID(instance);
   NexeLoadManager* load_manager = GetNexeLoadManager(instance);
   DCHECK(load_manager);
   content::PepperPluginInstance* plugin_instance =
       content::PepperPluginInstance::Get(instance);
   DCHECK(plugin_instance);
   if (!routing_id || !load_manager || !plugin_instance) {
-    if (nexe_file_info->handle != PP_kInvalidFileHandle) {
-      base::File closer(nexe_file_info->handle);
-    }
     ppapi::PpapiGlobals::Get()->GetMainThreadMessageLoop()->PostTask(
         FROM_HERE, base::Bind(callback.func, callback.user_data,
                               static_cast<int32_t>(PP_ERROR_FAILED)));
     return;
   }
 
   InstanceInfo instance_info;
   instance_info.url = GURL(alleged_url);
 
   uint32_t perm_bits = ppapi::PERMISSION_NONE;
@@ skipping 15 matching lines @@
         const GURL gurl(resource_prefetch_request_list[i].resource_url);
         // Important security check. Do not remove.
         if (!CanOpenViaFastPath(plugin_instance, gurl)) {
           resource_prefetch_request_list.clear();
           break;
         }
       }
     }
   }
 
-  IPC::PlatformFileForTransit nexe_for_transit =
-      IPC::InvalidPlatformFileForTransit();
-#if defined(OS_POSIX)
-  if (nexe_file_info->handle != PP_kInvalidFileHandle)
-    nexe_for_transit = base::FileDescriptor(nexe_file_info->handle, true);
-#elif defined(OS_WIN)
-  nexe_for_transit = IPC::PlatformFileForTransit(nexe_file_info->handle,
-                                                 base::GetCurrentProcId());
-#else
-# error Unsupported target platform.
-#endif
-
   std::string error_message_string;
-  NaClLaunchResult launch_result;
-  if (!sender->Send(new NaClHostMsg_LaunchNaCl(
-          NaClLaunchParams(
-              instance_info.url.spec(),
-              nexe_for_transit,
-              nexe_file_info->token_lo,
-              nexe_file_info->token_hi,
-              resource_prefetch_request_list,
-              routing_id,
-              perm_bits,
-              PP_ToBool(uses_nonsfi_mode),
-              process_type),
-          &launch_result,
-          &error_message_string))) {
+  mojom::NaClLaunchResultPtr launch_result;
+  if (!g_nacl_host_connection.Get().host()->LaunchNaCl(
+          mojom::NaClLaunchParams::New(
+              instance_info.url, std::move(nexe_file), nexe_file_info->token_lo,
+              nexe_file_info->token_hi, resource_prefetch_request_list,
+              routing_id, perm_bits, PP_ToBool(uses_nonsfi_mode), process_type),
+          &launch_result, &error_message_string)) {
     ppapi::PpapiGlobals::Get()->GetMainThreadMessageLoop()->PostTask(
         FROM_HERE,
         base::Bind(callback.func, callback.user_data,
                    static_cast<int32_t>(PP_ERROR_FAILED)));
     return;
   }
 
   load_manager->set_nonsfi(PP_ToBool(uses_nonsfi_mode));
 
   if (!error_message_string.empty()) {
-    // Even on error, some FDs/handles may be passed to here.
-    // We must release those resources.
-    // See also nacl_process_host.cc.
-    if (base::SharedMemory::IsHandleValid(
-            launch_result.crash_info_shmem_handle))
-      base::SharedMemory::CloseHandle(launch_result.crash_info_shmem_handle);
-
     if (PP_ToBool(main_service_runtime)) {
       load_manager->ReportLoadError(PP_NACL_ERROR_SEL_LDR_LAUNCH,
                                     "ServiceRuntime: failed to start",
                                     error_message_string);
     }
     ppapi::PpapiGlobals::Get()->GetMainThreadMessageLoop()->PostTask(
         FROM_HERE,
         base::Bind(callback.func, callback.user_data,
                    static_cast<int32_t>(PP_ERROR_FAILED)));
     return;
   }
+  DCHECK(launch_result);
 
-  instance_info.channel_handle = launch_result.ppapi_ipc_channel_handle;
-  instance_info.plugin_pid = launch_result.plugin_pid;
-  instance_info.plugin_child_id = launch_result.plugin_child_id;
+  instance_info.channel_handle =
+      launch_result->ppapi_ipc_channel_handle.release();
+  instance_info.plugin_pid = launch_result->plugin_pid;
+  instance_info.plugin_child_id = launch_result->plugin_child_id;
 
   // Don't save instance_info if channel handle is invalid.
   if (IsValidChannelHandle(instance_info.channel_handle)) {
     if (process_type == kPNaClTranslatorProcessType) {
       // Return an IPC channel which allows communicating with a PNaCl
       // translator process.
       *translator_channel = IPC::SyncChannel::Create(
           instance_info.channel_handle, IPC::Channel::MODE_CLIENT,
           new NoOpListener, content::RenderThread::Get()->GetIOTaskRunner(),
           true, content::RenderThread::Get()->GetShutdownEvent());
     } else {
       // Save the channel handle for when StartPpapiProxy() is called.
       NaClPluginInstance* nacl_plugin_instance =
           GetNaClPluginInstance(instance);
       nacl_plugin_instance->instance_info.reset(
           new InstanceInfo(instance_info));
     }
   }
 
   // Store the crash information shared memory handle.
   load_manager->set_crash_info_shmem_handle(
-      launch_result.crash_info_shmem_handle);
+      std::move(launch_result->crash_info_shmem_handle));
 
   // Create the trusted plugin channel.
-  if (IsValidChannelHandle(launch_result.trusted_ipc_channel_handle)) {
+  if (launch_result->trusted_ipc_channel_handle.is_pending()) {
     bool is_helper_nexe = !PP_ToBool(main_service_runtime);
     std::unique_ptr<TrustedPluginChannel> trusted_plugin_channel(
         new TrustedPluginChannel(
-            load_manager,
-            mojo::MakeRequest<mojom::NaClRendererHost>(
-                mojo::ScopedMessagePipeHandle(
-                    launch_result.trusted_ipc_channel_handle.mojo_handle)),
+            load_manager, std::move(launch_result->trusted_ipc_channel_handle),
             is_helper_nexe));
     load_manager->set_trusted_plugin_channel(std::move(trusted_plugin_channel));
   } else {
     PostPPCompletionCallback(callback, PP_ERROR_FAILED);
     return;
   }
 
   // Create the manifest service handle as well.
-  if (IsValidChannelHandle(launch_result.manifest_service_ipc_channel_handle)) {
+  if (launch_result->manifest_service_ipc_channel_handle.is_valid()) {
     std::unique_ptr<ManifestServiceChannel> manifest_service_channel(
         new ManifestServiceChannel(
-            launch_result.manifest_service_ipc_channel_handle,
+            launch_result->manifest_service_ipc_channel_handle.release(),
             base::Bind(&PostPPCompletionCallback, callback),
             std::move(manifest_service_proxy),
             content::RenderThread::Get()->GetShutdownEvent()));
     load_manager->set_manifest_service_channel(
         std::move(manifest_service_channel));
   }
 }
 
 namespace {
 
@@ skipping 62 matching lines @@
     replace_pos = r.find_first_not_of(kWhiteList);
   }
   return r;
 }
 
 PP_FileHandle GetReadonlyPnaclFd(const char* url,
                                  bool is_executable,
                                  uint64_t* nonce_lo,
                                  uint64_t* nonce_hi) {
   std::string filename = PnaclComponentURLToFilename(url);
-  IPC::PlatformFileForTransit out_fd = IPC::InvalidPlatformFileForTransit();
-  IPC::Sender* sender = content::RenderThread::Get();
-  DCHECK(sender);
-  if (!sender->Send(new NaClHostMsg_GetReadonlyPnaclFD(
-          std::string(filename), is_executable,
-          &out_fd, nonce_lo, nonce_hi))) {
+  base::File file;
+  if (!g_nacl_host_connection.Get().host()->GetReadonlyPnaclFd(
+          filename, is_executable, &file, nonce_lo, nonce_hi)) {
     return PP_kInvalidFileHandle;
   }
-  if (out_fd == IPC::InvalidPlatformFileForTransit()) {
-    return PP_kInvalidFileHandle;
-  }
-  return IPC::PlatformFileForTransitToPlatformFile(out_fd);
+  return file.TakePlatformFile();
 }
 
 }  // namespace
 
 // static
 void PPBNaClPrivate::GetReadExecPnaclFd(const char* url,
                                         PP_NaClFileInfo* out_file_info) {
   *out_file_info = kInvalidNaClFileInfo;
   out_file_info->handle = GetReadonlyPnaclFd(url, true /* is_executable */,
                                              &out_file_info->token_lo,
                                              &out_file_info->token_hi);
 }
 
 // static
 PP_FileHandle PPBNaClPrivate::CreateTemporaryFile(PP_Instance instance) {
-  IPC::PlatformFileForTransit transit_fd = IPC::InvalidPlatformFileForTransit();
-  IPC::Sender* sender = content::RenderThread::Get();
-  DCHECK(sender);
-  if (!sender->Send(new NaClHostMsg_NaClCreateTemporaryFile(
-          &transit_fd))) {
+  base::File file;
+  if (!g_nacl_host_connection.Get().host()->NaClCreateTemporaryFile(&file)) {
     return PP_kInvalidFileHandle;
   }
-
-  if (transit_fd == IPC::InvalidPlatformFileForTransit()) {
-    return PP_kInvalidFileHandle;
-  }
-
-  return IPC::PlatformFileForTransitToPlatformFile(transit_fd);
+  return file.TakePlatformFile();
 }
 
 // static
 int32_t PPBNaClPrivate::GetNumberOfProcessors() {
-  IPC::Sender* sender = content::RenderThread::Get();
-  DCHECK(sender);
   int32_t num_processors = 1;
-  return sender->Send(new NaClHostMsg_NaClGetNumProcessors(&num_processors)) ?
-      num_processors : 1;
+  return g_nacl_host_connection.Get().host()->NaClGetNumProcessors(
+             &num_processors)
+             ? num_processors
+             : 1;
 }
 
 namespace {
 
 void GetNexeFd(PP_Instance instance,
                const std::string& pexe_url,
                uint32_t opt_level,
                const base::Time& last_modified_time,
                const std::string& etag,
                bool has_no_store_header,
@@ skipping 76 matching lines @@
     std::string uma_suffix(use_subzero ? ".Subzero" : ".LLC");
     LogTranslationFinishedUMA("", opt_level, kUnknownOptLevel, nexe_size,
                               pexe_size, compile_time_us, total_time);
     LogTranslationFinishedUMA(uma_suffix, opt_level, kUnknownOptLevel,
                               nexe_size, pexe_size, compile_time_us,
                               total_time);
   }
 
   // If the resource host isn't initialized, don't try to do that here.
   // Just return because something is already very wrong.
-  if (g_pnacl_resource_host.Get().get() == NULL)
+  if (g_pnacl_resource_host.Get() == NULL)
     return;
   g_pnacl_resource_host.Get()->ReportTranslationFinished(instance, success);
 
   // Record the pexe size for reporting in a later load event.
   NaClPluginInstance* nacl_plugin_instance = GetNaClPluginInstance(instance);
   if (nacl_plugin_instance) {
     nacl_plugin_instance->pexe_size = pexe_size;
   }
 }
 
@@ skipping 11 matching lines @@
   content::PepperPluginInstance* plugin_instance =
       content::PepperPluginInstance::Get(instance);
   if (!plugin_instance)
     return PP_kInvalidFileHandle;
 
   GURL gurl(file_url);
   // Important security check. Do not remove.
   if (!CanOpenViaFastPath(plugin_instance, gurl))
     return PP_kInvalidFileHandle;
 
-  IPC::PlatformFileForTransit out_fd = IPC::InvalidPlatformFileForTransit();
-  IPC::Sender* sender = content::RenderThread::Get();
-  DCHECK(sender);
   *nonce_lo = 0;
   *nonce_hi = 0;
   base::FilePath file_path;
-  if (!sender->Send(
-      new NaClHostMsg_OpenNaClExecutable(GetRoutingID(instance),
-                                         GURL(file_url),
-                                         !load_manager->nonsfi(),
-                                         &out_fd,
-                                         nonce_lo,
-                                         nonce_hi))) {
+  base::File file;
+  if (!g_nacl_host_connection.Get().host()->OpenNaClExecutable(
+          GetRoutingID(instance), GURL(file_url), !load_manager->nonsfi(),
+          &file, nonce_lo, nonce_hi)) {
     return PP_kInvalidFileHandle;
   }
-
-  if (out_fd == IPC::InvalidPlatformFileForTransit())
-    return PP_kInvalidFileHandle;
-
-  return IPC::PlatformFileForTransitToPlatformFile(out_fd);
+  return file.TakePlatformFile();
 }
 
 }  // namespace
 
 // static
 void PPBNaClPrivate::DispatchEvent(PP_Instance instance,
                                    PP_NaClEventType event_type,
                                    const char* resource_url,
                                    PP_Bool length_is_computable,
                                    uint64_t loaded_bytes,
@@ skipping 48 matching lines @@
 namespace {
 
 PP_Bool NaClDebugEnabledForURL(const char* alleged_nmf_url) {
   if (!base::CommandLine::ForCurrentProcess()->HasSwitch(
           switches::kEnableNaClDebug))
     return PP_FALSE;
   IPC::Sender* sender = content::RenderThread::Get();
   DCHECK(sender);
   bool should_debug = false;
   return PP_FromBool(
-      sender->Send(new NaClHostMsg_NaClDebugEnabledForURL(GURL(alleged_nmf_url),
-                                                          &should_debug)) &&
+      g_nacl_host_connection.Get().host()->NaClDebugEnabledForURL(
+          GURL(alleged_nmf_url), &should_debug) &&
       should_debug);
 }
 
 }  // namespace
 
 // static
 void PPBNaClPrivate::InitializePlugin(PP_Instance instance,
                                       uint32_t argc,
                                       const char* argn[],
                                       const char* argv[]) {
@@ skipping 824 matching lines @@
   // Mark the request as requesting a PNaCl bitcode file,
   // so that component updater can detect this user action.
   url_request.addHTTPHeaderField(
       blink::WebString::fromUTF8("Accept"),
       blink::WebString::fromUTF8("application/x-pnacl, */*"));
   url_request.setRequestContext(blink::WebURLRequest::RequestContextObject);
   downloader->Load(url_request);
 }
 
 }  // namespace nacl