Home | History | Annotate | Download | only in mojo 
      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/browser/mojo/mojo_application_host.h"
      6 
      7 #include "content/common/mojo/mojo_messages.h"
      8 #include "content/public/browser/browser_thread.h"
      9 #include "ipc/ipc_sender.h"
     10 #include "mojo/embedder/platform_channel_pair.h"
     11 
     12 namespace content {
     13 namespace {
     14 
     15 base::PlatformFile PlatformFileFromScopedPlatformHandle(
     16     mojo::embedder::ScopedPlatformHandle handle) {
     17 #if defined(OS_POSIX)
     18   return handle.release().fd;
     19 #elif defined(OS_WIN)
     20   return handle.release().handle;
     21 #endif
     22 }
     23 
     24 }  // namespace
     25 
     26 MojoApplicationHost::MojoApplicationHost() : did_activate_(false) {
     27 }
     28 
     29 MojoApplicationHost::~MojoApplicationHost() {
     30 }
     31 
     32 bool MojoApplicationHost::Init() {
     33   DCHECK(!client_handle_.is_valid()) << "Already initialized!";
     34 
     35   mojo::embedder::PlatformChannelPair channel_pair;
     36 
     37   mojo::ScopedMessagePipeHandle message_pipe = channel_init_.Init(
     38       PlatformFileFromScopedPlatformHandle(channel_pair.PassServerHandle()),
     39       BrowserThread::GetMessageLoopProxyForThread(BrowserThread::IO));
     40   if (!message_pipe.is_valid())
     41     return false;
     42 
     43   // Forward this to the client once we know its process handle.
     44   client_handle_ = channel_pair.PassClientHandle();
     45 
     46   service_registry_.BindRemoteServiceProvider(message_pipe.Pass());
     47   return true;
     48 }
     49 
     50 bool MojoApplicationHost::Activate(IPC::Sender* sender,
     51                                    base::ProcessHandle process_handle) {
     52   DCHECK(!did_activate_);
     53   DCHECK(client_handle_.is_valid());
     54 
     55   base::PlatformFile client_file =
     56       PlatformFileFromScopedPlatformHandle(client_handle_.Pass());
     57   did_activate_ = sender->Send(new MojoMsg_Activate(
     58       IPC::GetFileHandleForProcess(client_file, process_handle, true)));
     59   return did_activate_;
     60 }
     61 
     62 void MojoApplicationHost::WillDestroySoon() {
     63   channel_init_.WillDestroySoon();
     64 }
     65 
     66 }  // namespace content
     67