Use token-based initialisation for the utility process MojoApplication.

content/browser/mojo/mojo_application_host.cc

 // Copyright 2014 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/browser/mojo/mojo_application_host.h"
 
 #include <utility>
 
 #include "build/build_config.h"
 #include "content/common/mojo/mojo_messages.h"
 #include "content/public/browser/browser_thread.h"
 #include "ipc/ipc_sender.h"
+#include "mojo/edk/embedder/embedder.h"
 #include "mojo/edk/embedder/platform_channel_pair.h"
 
 namespace content {
 namespace {
 
 class ApplicationSetupImpl : public mojom::ApplicationSetup {
  public:
   ApplicationSetupImpl(ServiceRegistryImpl* service_registry,
                        mojo::InterfaceRequest<mojom::ApplicationSetup> request)
       : binding_(this, std::move(request)),
@@ skipping 54 matching lines @@
 void MojoApplicationHost::Activate(IPC::Sender* sender,
                                    base::ProcessHandle process_handle) {
   DCHECK(!did_activate_);
   DCHECK(client_handle_.is_valid());
 
   base::PlatformFile client_file = client_handle_.release().handle;
   did_activate_ = sender->Send(new MojoMsg_Activate(
       IPC::GetPlatformFileForTransit(client_file, true)));
 }
 
+std::string MojoApplicationHost::InitWithToken() {
+  DCHECK(!client_handle_.is_valid()) << "Already initialized!";
+  DCHECK(!did_activate_);
+
+  std::string token = mojo::edk::GenerateRandomToken();
+  mojo::ScopedMessagePipeHandle pipe =
+      mojo::edk::CreateParentMessagePipe(token);
+  DCHECK(pipe.is_valid());
+  application_setup_.reset(new ApplicationSetupImpl(
+      &service_registry_,
+      mojo::MakeRequest<mojom::ApplicationSetup>(std::move(pipe))));
+
+  did_activate_ = true;
+  return token;
+}
+
+mojo::ScopedMessagePipeHandle MojoApplicationHost::InitWithPipe() {
+  DCHECK(!client_handle_.is_valid()) << "Already initialized!";
+  DCHECK(!did_activate_);
+
+  mojo::MessagePipe handles;
+  DCHECK(handles.handle0.is_valid());
+  DCHECK(handles.handle1.is_valid());
+  application_setup_.reset(new ApplicationSetupImpl(
+      &service_registry_,
+      mojo::MakeRequest<mojom::ApplicationSetup>(std::move(handles.handle0))));
+
+  did_activate_ = true;
+  return std::move(handles.handle1);
+}
+
 void MojoApplicationHost::OverrideIOTaskRunnerForTest(
     scoped_refptr<base::TaskRunner> io_task_runner) {
   io_task_runner_override_ = io_task_runner;
 }
 
 
 }  // namespace content