Mojo EDK: Add safe process connection API

chrome/service/service_utility_process_host.cc

 // 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/service/service_utility_process_host.h"
 
 #include <stdint.h>
 
 #include <queue>
 #include <utility>
@@ skipping 151 matching lines @@
   int current_page_;
   int pages_in_progress_;
 };
 
 ServiceUtilityProcessHost::ServiceUtilityProcessHost(
     Client* client,
     base::SingleThreadTaskRunner* client_task_runner)
     : client_(client),
       client_task_runner_(client_task_runner),
       waiting_for_reply_(false),
-      mojo_child_token_(mojo::edk::GenerateRandomToken()),
       weak_ptr_factory_(this) {
   child_process_host_.reset(ChildProcessHost::Create(this));
 }
 
 ServiceUtilityProcessHost::~ServiceUtilityProcessHost() {
   // We need to kill the child process when the host dies.
   process_.Terminate(content::RESULT_CODE_NORMAL_EXIT, false);
 }
 
 bool ServiceUtilityProcessHost::StartRenderPDFPagesToMetafile(
@@ skipping 31 matching lines @@
   if (!StartProcess(true))
     return false;
   DCHECK(!waiting_for_reply_);
   waiting_for_reply_ = true;
   return Send(
       new ChromeUtilityMsg_GetPrinterSemanticCapsAndDefaults(printer_name));
 }
 
 bool ServiceUtilityProcessHost::StartProcess(bool no_sandbox) {
   std::string mojo_channel_token =
-      child_process_host_->CreateChannelMojo(mojo_child_token_);
+      child_process_host_->CreateChannelMojo(&process_connection_);
   if (mojo_channel_token.empty())
     return false;
 
   base::FilePath exe_path = GetUtilityProcessCmd();
   if (exe_path.empty()) {
     NOTREACHED() << "Unable to get utility process binary name.";
     return false;
   }
 
   base::CommandLine cmd_line(exe_path);
@@ skipping 36 matching lines @@
     ServiceSandboxedProcessLauncherDelegate delegate;
     base::Process process;
     sandbox::ResultCode result = content::StartSandboxedProcess(
         &delegate, cmd_line, handles, &process);
     if (result == sandbox::SBOX_ALL_OK) {
       process_ = std::move(process);
       success = true;
     }
   }
 
-  if (success) {
-    mojo::edk::ChildProcessLaunched(process_.Handle(),
-                                    std::move(parent_handle),
-                                    mojo_child_token_);
-  } else {
-    mojo::edk::ChildProcessLaunchFailed(mojo_child_token_);
-  }
+  if (success)
+    process_connection_.Connect(process_.Handle(), std::move(parent_handle));
+
   return success;
 }
 
 bool ServiceUtilityProcessHost::Send(IPC::Message* msg) {
   if (child_process_host_)
     return child_process_host_->Send(msg);
   delete msg;
   return false;
 }
 
@@ skipping 159 matching lines @@
     return false;
   }
   printing::Emf emf;
   if (!emf.InitFromData(data.data(), data.size())) {
     OnRenderPDFPagesToMetafileDone(false);
     return false;
   }
   OnRenderPDFPagesToMetafilePageDone(scale_factor, emf);
   return true;
 }