[mojo] Delete third_party/mojo

mojo/shell/runner/host/child_process_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 "mojo/shell/runner/host/child_process_host.h"
 
 #include <stdint.h>
 
 #include <utility>
 
 #include "base/bind.h"
 #include "base/command_line.h"
 #include "base/location.h"
 #include "base/logging.h"
 #include "base/macros.h"
 #include "base/message_loop/message_loop.h"
 #include "base/process/kill.h"
 #include "base/process/launch.h"
 #include "base/task_runner.h"
 #include "base/thread_task_runner_handle.h"
 #include "mojo/edk/embedder/embedder.h"
 #include "mojo/public/cpp/bindings/interface_ptr_info.h"
 #include "mojo/public/cpp/system/core.h"
 #include "mojo/shell/runner/common/switches.h"
-#include "third_party/mojo/src/mojo/edk/embedder/embedder.h"
 
 #if defined(OS_LINUX) && !defined(OS_ANDROID)
 #include "sandbox/linux/services/namespace_sandbox.h"
 #endif
 
 #if defined(OS_WIN)
 #include "base/win/windows_version.h"
 #endif
 
 namespace mojo {
@@ skipping 21 matching lines @@
 }
 
 ChildProcessHost::PipeHolder::~PipeHolder() {}
 
 ChildProcessHost::ChildProcessHost(base::TaskRunner* launch_process_runner,
                                    bool start_sandboxed,
                                    const base::FilePath& app_path)
     : launch_process_runner_(launch_process_runner),
       start_sandboxed_(start_sandboxed),
       app_path_(app_path),
-      channel_info_(nullptr),
       start_child_process_event_(false, false),
       weak_factory_(this) {
   pipe_holder_ = new PipeHolder();
-  if (base::CommandLine::ForCurrentProcess()->HasSwitch("use-new-edk")) {
-    node_channel_.reset(new edk::PlatformChannelPair);
-    primordial_pipe_token_ = edk::GenerateRandomToken();
-  } else {
-    pipe_holder_->SetPipe(embedder::CreateChannel(
-        platform_channel_pair_.PassServerHandle(),
-        base::Bind(&ChildProcessHost::DidCreateChannel, base::Unretained(this)),
-        base::ThreadTaskRunnerHandle::Get()));
-    OnMessagePipeCreated();
-  }
+  node_channel_.reset(new edk::PlatformChannelPair);
+  primordial_pipe_token_ = edk::GenerateRandomToken();
 }
 
 ChildProcessHost::ChildProcessHost(ScopedHandle channel)
     : launch_process_runner_(nullptr),
       start_sandboxed_(false),
-      channel_info_(nullptr),
       start_child_process_event_(false, false),
       weak_factory_(this) {
   CHECK(channel.is_valid());
   ScopedMessagePipeHandle handle(MessagePipeHandle(channel.release().value()));
   controller_.Bind(
       InterfacePtrInfo<mojom::ChildController>(std::move(handle), 0u));
 }
 
 ChildProcessHost::~ChildProcessHost() {
   if (!app_path_.empty())
     CHECK(!controller_) << "Destroying ChildProcessHost before calling Join";
 }
 
 void ChildProcessHost::Start(const ProcessReadyCallback& callback) {
   DCHECK(!child_process_.IsValid());
   DCHECK(process_ready_callback_.is_null());
 
   process_ready_callback_ = callback;
-  if (base::CommandLine::ForCurrentProcess()->HasSwitch("use-new-edk")) {
-    // With the new EDK, bootstrap message pipes are created asynchronously.
-    // We recieve the bound pipe (if successful) on an arbitrary thread,
-    // stash it in the thread-safe |pipe_holder_|, and then try to call
-    // OnMessagePipeCreated() on the host's main thread.
-    //
-    // Because of the way the launcher process shuts down, it's possible for
-    // the main thread's MessageLoop to stop running (but not yet be destroyed!)
-    // while this boostrap is pending, resulting in OnMessagePipeCreated() never
-    // being called.
-    //
-    // A typical child process (i.e. one using ApplicationImpl to bind the other
-    // end of this pipe) may hang forever waiting for an Initialize() message
-    // unless the pipe is closed. This in turn means that Join() could hang
-    // waiting for the process to exit. Deadlock!
-    //
-    // |pipe_holder_| exists for this reason. If it's still holding onto the
-    // pipe when Join() is called, the pipe will be closed.
-    DCHECK(!primordial_pipe_token_.empty());
-    edk::CreateParentMessagePipe(
-        primordial_pipe_token_,
-        base::Bind(&OnParentMessagePipeCreated, pipe_holder_,
-                   base::ThreadTaskRunnerHandle::Get(),
-                   base::Bind(&ChildProcessHost::OnMessagePipeCreated,
-                              weak_factory_.GetWeakPtr())));
-  }
+  // With the new EDK, bootstrap message pipes are created asynchronously.

[jam, 2016/02/08 17:32:12]

nit: remove new edk since there's only one now?

[Ken Rockot(use gerrit already), 2016/02/08 17:51:18]

Done

+  // We recieve the bound pipe (if successful) on an arbitrary thread,
+  // stash it in the thread-safe |pipe_holder_|, and then try to call
+  // OnMessagePipeCreated() on the host's main thread.
+  //
+  // Because of the way the launcher process shuts down, it's possible for
+  // the main thread's MessageLoop to stop running (but not yet be destroyed!)
+  // while this boostrap is pending, resulting in OnMessagePipeCreated() never
+  // being called.
+  //
+  // A typical child process (i.e. one using ApplicationImpl to bind the other
+  // end of this pipe) may hang forever waiting for an Initialize() message
+  // unless the pipe is closed. This in turn means that Join() could hang
+  // waiting for the process to exit. Deadlock!
+  //
+  // |pipe_holder_| exists for this reason. If it's still holding onto the
+  // pipe when Join() is called, the pipe will be closed.
+  DCHECK(!primordial_pipe_token_.empty());
+  edk::CreateParentMessagePipe(
+      primordial_pipe_token_,
+      base::Bind(&OnParentMessagePipeCreated, pipe_holder_,
+                 base::ThreadTaskRunnerHandle::Get(),
+                 base::Bind(&ChildProcessHost::OnMessagePipeCreated,
+                            weak_factory_.GetWeakPtr())));
 
   launch_process_runner_->PostTaskAndReply(
       FROM_HERE,
       base::Bind(&ChildProcessHost::DoLaunch, base::Unretained(this)),
       base::Bind(&ChildProcessHost::DidStart, weak_factory_.GetWeakPtr()));
 }
 
 int ChildProcessHost::Join() {
   if (controller_)  // We use this as a signal that Start was called.
     start_child_process_event_.Wait();
@@ skipping 113 matching lines @@
                  << " support.";
     }
   } else
 #endif
     child_process_ = base::LaunchProcess(child_command_line, options);
 
   if (child_process_.IsValid()) {
     platform_channel_pair_.ChildProcessLaunched();
     if (node_channel_.get()) {
       node_channel_->ChildProcessLaunched();
-      mojo::embedder::ChildProcessLaunched(
+      mojo::edk::ChildProcessLaunched(
           child_process_.Handle(),
-          mojo::embedder::ScopedPlatformHandle(mojo::embedder::PlatformHandle(
+          mojo::edk::ScopedPlatformHandle(mojo::edk::PlatformHandle(
               node_channel_->PassServerHandle().release().handle)));
     }
   }
   start_child_process_event_.Signal();
 }
 
 void ChildProcessHost::AppCompleted(int32_t result) {
   if (!on_app_complete_.is_null()) {
     auto on_app_complete = on_app_complete_;
     on_app_complete_.reset();
     on_app_complete.Run(result);
   }
 }
 
-void ChildProcessHost::DidCreateChannel(embedder::ChannelInfo* channel_info) {
-  DVLOG(2) << "AppChildProcessHost::DidCreateChannel()";
-
-  DCHECK(channel_info ||
-         base::CommandLine::ForCurrentProcess()->HasSwitch("use-new-edk"));
-  channel_info_ = channel_info;
-}
-
 void ChildProcessHost::OnMessagePipeCreated() {
   controller_.Bind(
       InterfacePtrInfo<mojom::ChildController>(pipe_holder_->PassPipe(), 0u));
   MaybeNotifyProcessReady();
 }
 
 void ChildProcessHost::MaybeNotifyProcessReady() {
   if (controller_.is_bound() && child_process_.IsValid())
     process_ready_callback_.Run(child_process_.Pid());
 }
 
 // static
 void ChildProcessHost::OnParentMessagePipeCreated(
     scoped_refptr<PipeHolder> holder,
     scoped_refptr<base::TaskRunner> callback_task_runner,
     const base::Closure& callback,
     ScopedMessagePipeHandle pipe) {
   holder->SetPipe(std::move(pipe));
   callback_task_runner->PostTask(FROM_HERE, callback);
 }
 
 }  // namespace shell
 }  // namespace mojo