content/child/mojo/mojo_application.cc

   1 // Copyright 2014 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "content/child/mojo/mojo_application.h"
   6
   7 #include "content/child/child_process.h"
   8 #include "content/common/application_setup.mojom.h"
   9 #include "content/common/mojo/channel_init.h"
  10 #include "content/common/mojo/mojo_messages.h"
  11 #include "ipc/ipc_message.h"
  12 #include "third_party/mojo/src/mojo/public/cpp/bindings/interface_ptr.h"
  13
  14 namespace content {
  15
  16 MojoApplication::MojoApplication(
  17     scoped_refptr<base::SequencedTaskRunner> io_task_runner)
  18     : io_task_runner_(io_task_runner) {
  19   DCHECK(io_task_runner_);
  20 }
  21
  22 MojoApplication::~MojoApplication() {
  23 }
  24
  25 bool MojoApplication::OnMessageReceived(const IPC::Message& msg) {
  26   bool handled = true;
  27   IPC_BEGIN_MESSAGE_MAP(MojoApplication, msg)
  28     IPC_MESSAGE_HANDLER(MojoMsg_Activate, OnActivate)
  29     IPC_MESSAGE_UNHANDLED(handled = false)
  30   IPC_END_MESSAGE_MAP()
  31   return handled;
  32 }
  33
  34 void MojoApplication::OnActivate(
  35     const IPC::PlatformFileForTransit& file) {
  36 #if defined(OS_POSIX)
  37   base::PlatformFile handle = file.fd;
  38 #elif defined(OS_WIN)
  39   base::PlatformFile handle = file;
  40 #endif
  41
  42   mojo::ScopedMessagePipeHandle message_pipe =
  43       channel_init_.Init(handle, io_task_runner_);
  44   DCHECK(message_pipe.is_valid());
  45
  46   ApplicationSetupPtr application_setup;
  47   application_setup.Bind(
  48       mojo::InterfacePtrInfo<ApplicationSetup>(message_pipe.Pass(), 0u));
  49
  50   mojo::ServiceProviderPtr services;
  51   mojo::ServiceProviderPtr exposed_services;
  52   service_registry_.Bind(GetProxy(&exposed_services));
  53   application_setup->ExchangeServiceProviders(GetProxy(&services),
  54                                               exposed_services.Pass());
  55   service_registry_.BindRemoteServiceProvider(services.Pass());
  56 }
  57
  58 }  // namespace content