[mojo] Ports EDK

content/child/mojo/mojo_application.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/child/mojo/mojo_application.h"
 
 #include <utility>
 
 #include "build/build_config.h"
 #include "content/child/child_process.h"
 #include "content/common/application_setup.mojom.h"
 #include "content/common/mojo/channel_init.h"
 #include "content/common/mojo/mojo_messages.h"
 #include "ipc/ipc_message.h"
 #include "mojo/public/cpp/bindings/interface_ptr.h"
 
 namespace content {
 
 MojoApplication::MojoApplication(
     scoped_refptr<base::SequencedTaskRunner> io_task_runner)
-    : io_task_runner_(io_task_runner) {
+    : io_task_runner_(io_task_runner),
+      weak_factory_(this) {
   DCHECK(io_task_runner_);
 }
 
 MojoApplication::~MojoApplication() {
 }
 
 bool MojoApplication::OnMessageReceived(const IPC::Message& msg) {
   bool handled = true;
   IPC_BEGIN_MESSAGE_MAP(MojoApplication, msg)
     IPC_MESSAGE_HANDLER(MojoMsg_Activate, OnActivate)
     IPC_MESSAGE_UNHANDLED(handled = false)
   IPC_END_MESSAGE_MAP()
   return handled;
 }
 
 void MojoApplication::OnActivate(
     const IPC::PlatformFileForTransit& file) {
 #if defined(OS_POSIX)
   base::PlatformFile handle = file.fd;
 #elif defined(OS_WIN)
   base::PlatformFile handle = file;
 #endif
 
-  mojo::ScopedMessagePipeHandle message_pipe =
-      channel_init_.Init(handle, io_task_runner_);
-  DCHECK(message_pipe.is_valid());
+  channel_init_.Init(handle, io_task_runner_,
+                     base::Bind(&MojoApplication::OnMessagePipeCreated,
+                                weak_factory_.GetWeakPtr()));
+}
+
+void MojoApplication::OnMessagePipeCreated(mojo::ScopedMessagePipeHandle pipe) {
+  DCHECK(pipe.is_valid());
 
   ApplicationSetupPtr application_setup;
   application_setup.Bind(
-      mojo::InterfacePtrInfo<ApplicationSetup>(std::move(message_pipe), 0u));
+      mojo::InterfacePtrInfo<ApplicationSetup>(std::move(pipe), 0u));
 
   mojo::ServiceProviderPtr services;
   mojo::ServiceProviderPtr exposed_services;
   service_registry_.Bind(GetProxy(&exposed_services));
   application_setup->ExchangeServiceProviders(GetProxy(&services),
                                               std::move(exposed_services));
   service_registry_.BindRemoteServiceProvider(std::move(services));
 }
 
 }  // namespace content