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 |