Use ChannelMojo for the utility process.

content/common/child_process_host_impl.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 "content/common/child_process_host_impl.h"
 
 #include <limits>
 
 #include "base/atomic_sequence_num.h"
 #include "base/command_line.h"
@@ skipping 13 matching lines @@
 #include "content/common/child_process_messages.h"
 #include "content/public/common/child_process_host_delegate.h"
 #include "content/public/common/content_paths.h"
 #include "content/public/common/content_switches.h"
 #include "gpu/ipc/client/gpu_memory_buffer_impl_shared_memory.h"
 #include "ipc/attachment_broker.h"
 #include "ipc/attachment_broker_privileged.h"
 #include "ipc/ipc_channel.h"
 #include "ipc/ipc_logging.h"
 #include "ipc/message_filter.h"
+#include "ipc/mojo/ipc_channel_mojo.h"
+#include "mojo/edk/embedder/embedder.h"
 
 #if defined(OS_LINUX)
 #include "base/linux_util.h"
 #elif defined(OS_WIN)
 #include "content/common/font_cache_dispatcher_win.h"
 #endif  // OS_LINUX
 
 namespace {
 
 // Global atomic to generate child process unique IDs.
@@ skipping 79 matching lines @@
   filters_.push_back(filter);
 
   if (channel_)
     filter->OnFilterAdded(channel_.get());
 }
 
 void ChildProcessHostImpl::ForceShutdown() {
   Send(new ChildProcessMsg_Shutdown());
 }
 
+std::string ChildProcessHostImpl::CreateChannelMojo() {
+  DCHECK(channel_id_.empty());
+  channel_id_ = mojo::edk::GenerateRandomToken();
+  mojo::ScopedMessagePipeHandle host_handle =
+      mojo::edk::CreateParentMessagePipe(channel_id_);
+  channel_ = IPC::ChannelMojo::Create(std::move(host_handle),
+                                      IPC::Channel::MODE_SERVER, this);
+  if (!channel_ || !CreateChannelCommon())
+    return std::string();
+
+  return channel_id_;
+}
+
 std::string ChildProcessHostImpl::CreateChannel() {
+  DCHECK(channel_id_.empty());
   channel_id_ = IPC::Channel::GenerateVerifiedChannelID(std::string());
   channel_ = IPC::Channel::CreateServer(channel_id_, this);
+  if (!channel_ || !CreateChannelCommon())
+    return std::string();
+
+  return channel_id_;
+}
+
+bool ChildProcessHostImpl::CreateChannelCommon() {

[ncarter (slow), 2016/05/10 16:50:10]

Consider calling this InitChannel()/ConnectChannel()/AttachChannel() or some
other name that describes what it does, rather than how it's called.

[Anand Mistry (off Chromium), 2016/05/11 00:21:22]

Done.

 #if USE_ATTACHMENT_BROKER
   IPC::AttachmentBroker::GetGlobal()->RegisterCommunicationChannel(
       channel_.get(), base::MessageLoopForIO::current()->task_runner());
 #endif
   if (!channel_->Connect()) {
 #if USE_ATTACHMENT_BROKER
     IPC::AttachmentBroker::GetGlobal()->DeregisterCommunicationChannel(
         channel_.get());
 #endif
-    return std::string();
+    return false;
   }
 
   for (size_t i = 0; i < filters_.size(); ++i)
     filters_[i]->OnFilterAdded(channel_.get());
 
   // Make sure these messages get sent first.
 #if defined(IPC_MESSAGE_LOG_ENABLED)
   bool enabled = IPC::Logging::GetInstance()->Enabled();
   Send(new ChildProcessMsg_SetIPCLoggingEnabled(enabled));
 #endif
 
   opening_channel_ = true;
 
-  return channel_id_;
+  return true;
 }
 
 bool ChildProcessHostImpl::IsChannelOpening() {
   return opening_channel_;
 }
 
 #if defined(OS_POSIX)
 base::ScopedFD ChildProcessHostImpl::TakeClientFileDescriptor() {
   return channel_->TakeClientFileDescriptor();
 }
@@ skipping 159 matching lines @@
 }
 
 void ChildProcessHostImpl::OnDeletedGpuMemoryBuffer(
     gfx::GpuMemoryBufferId id,
     const gpu::SyncToken& sync_token) {
   // Note: Nothing to do here as ownership of shared memory backed
   // GpuMemoryBuffers is passed with IPC.
 }
 
 }  // namespace content