| OLD | NEW |
| (Empty) |
| 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/renderer_host/render_process_host_mojo_impl.h" | |
| 6 | |
| 7 #include "base/platform_file.h" | |
| 8 #include "content/common/mojo/mojo_channel_init.h" | |
| 9 #include "content/common/mojo/mojo_messages.h" | |
| 10 #include "content/public/browser/browser_thread.h" | |
| 11 #include "content/public/browser/render_process_host.h" | |
| 12 #include "mojo/embedder/platform_channel_pair.h" | |
| 13 | |
| 14 namespace content { | |
| 15 | |
| 16 namespace { | |
| 17 | |
| 18 base::PlatformFile PlatformFileFromScopedPlatformHandle( | |
| 19 mojo::embedder::ScopedPlatformHandle handle) { | |
| 20 #if defined(OS_POSIX) | |
| 21 return handle.release().fd; | |
| 22 #elif defined(OS_WIN) | |
| 23 return handle.release().handle; | |
| 24 #endif | |
| 25 } | |
| 26 | |
| 27 } // namespace | |
| 28 | |
| 29 struct RenderProcessHostMojoImpl::PendingHandle { | |
| 30 PendingHandle() : view_routing_id(0) {} | |
| 31 | |
| 32 int32 view_routing_id; | |
| 33 mojo::ScopedMessagePipeHandle handle; | |
| 34 }; | |
| 35 | |
| 36 RenderProcessHostMojoImpl::RenderProcessHostMojoImpl(RenderProcessHost* host) | |
| 37 : host_(host) { | |
| 38 } | |
| 39 | |
| 40 RenderProcessHostMojoImpl::~RenderProcessHostMojoImpl() { | |
| 41 } | |
| 42 | |
| 43 void RenderProcessHostMojoImpl::SetWebUIHandle( | |
| 44 int32 view_routing_id, | |
| 45 mojo::ScopedMessagePipeHandle handle) { | |
| 46 base::ProcessHandle process = host_->GetHandle(); | |
| 47 if (process != base::kNullProcessHandle) { | |
| 48 CreateMojoChannel(process); // Does nothing if already connected. | |
| 49 if (!render_process_mojo_.is_null()) { | |
| 50 render_process_mojo_->SetWebUIHandle(view_routing_id, handle.Pass()); | |
| 51 return; | |
| 52 } | |
| 53 } | |
| 54 | |
| 55 // Remember the request, we'll attempt to reconnect once the child process is | |
| 56 // launched. | |
| 57 pending_handle_.reset(new PendingHandle); | |
| 58 pending_handle_->view_routing_id = view_routing_id; | |
| 59 pending_handle_->handle = handle.Pass(); | |
| 60 } | |
| 61 | |
| 62 void RenderProcessHostMojoImpl::OnProcessLaunched() { | |
| 63 if (pending_handle_) { | |
| 64 scoped_ptr<PendingHandle> handle(pending_handle_.Pass()); | |
| 65 SetWebUIHandle(handle->view_routing_id, handle->handle.Pass()); | |
| 66 } | |
| 67 } | |
| 68 | |
| 69 | |
| 70 void RenderProcessHostMojoImpl::CreateMojoChannel( | |
| 71 base::ProcessHandle process_handle) { | |
| 72 if (mojo_channel_init_.get()) | |
| 73 return; | |
| 74 | |
| 75 mojo::embedder::PlatformChannelPair channel_pair; | |
| 76 mojo_channel_init_.reset(new MojoChannelInit); | |
| 77 mojo_channel_init_->Init( | |
| 78 PlatformFileFromScopedPlatformHandle(channel_pair.PassServerHandle()), | |
| 79 BrowserThread::GetMessageLoopProxyForThread(BrowserThread::IO)); | |
| 80 if (!mojo_channel_init_->is_handle_valid()) | |
| 81 return; | |
| 82 base::PlatformFile client_file = | |
| 83 PlatformFileFromScopedPlatformHandle(channel_pair.PassClientHandle()); | |
| 84 host_->Send(new MojoMsg_ChannelCreated( | |
| 85 IPC::GetFileHandleForProcess(client_file, process_handle, | |
| 86 true))); | |
| 87 ScopedRenderProcessMojoHandle render_process_handle( | |
| 88 RenderProcessMojoHandle( | |
| 89 mojo_channel_init_->bootstrap_message_pipe().release().value())); | |
| 90 render_process_mojo_.reset(render_process_handle.Pass(), this); | |
| 91 } | |
| 92 | |
| 93 } // namespace content | |
| OLD | NEW |