| Index: content/browser/renderer_host/render_process_host_mojo_impl.cc
|
| diff --git a/content/browser/renderer_host/render_process_host_mojo_impl.cc b/content/browser/renderer_host/render_process_host_mojo_impl.cc
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..16348a6d21c19851811ab3ff9f12badeef2d491e
|
| --- /dev/null
|
| +++ b/content/browser/renderer_host/render_process_host_mojo_impl.cc
|
| @@ -0,0 +1,93 @@
|
| +// 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/browser/renderer_host/render_process_host_mojo_impl.h"
|
| +
|
| +#include "base/platform_file.h"
|
| +#include "content/common/mojo/mojo_channel_init.h"
|
| +#include "content/common/mojo/mojo_messages.h"
|
| +#include "content/public/browser/browser_thread.h"
|
| +#include "content/public/browser/render_process_host.h"
|
| +#include "mojo/embedder/platform_channel_pair.h"
|
| +
|
| +namespace content {
|
| +
|
| +namespace {
|
| +
|
| +base::PlatformFile PlatformFileFromScopedPlatformHandle(
|
| + mojo::embedder::ScopedPlatformHandle handle) {
|
| +#if defined(OS_POSIX)
|
| + return handle.release().fd;
|
| +#elif defined(OS_WIN)
|
| + return handle.release().handle;
|
| +#endif
|
| +}
|
| +
|
| +} // namespace
|
| +
|
| +struct RenderProcessHostMojoImpl::PendingHandle {
|
| + PendingHandle() : view_routing_id(0) {}
|
| +
|
| + int32 view_routing_id;
|
| + mojo::ScopedMessagePipeHandle handle;
|
| +};
|
| +
|
| +RenderProcessHostMojoImpl::RenderProcessHostMojoImpl(RenderProcessHost* host)
|
| + : host_(host) {
|
| +}
|
| +
|
| +RenderProcessHostMojoImpl::~RenderProcessHostMojoImpl() {
|
| +}
|
| +
|
| +void RenderProcessHostMojoImpl::SetWebUIHandle(
|
| + int32 view_routing_id,
|
| + mojo::ScopedMessagePipeHandle handle) {
|
| + base::ProcessHandle process = host_->GetHandle();
|
| + if (process != base::kNullProcessHandle) {
|
| + CreateMojoChannel(process); // Does nothing if already connected.
|
| + if (!render_process_mojo_.is_null()) {
|
| + render_process_mojo_->SetWebUIHandle(view_routing_id, handle.Pass());
|
| + return;
|
| + }
|
| + }
|
| +
|
| + // Remember the request, we'll attempt to reconnect once the child process is
|
| + // launched.
|
| + pending_handle_.reset(new PendingHandle);
|
| + pending_handle_->view_routing_id = view_routing_id;
|
| + pending_handle_->handle = handle.Pass();
|
| +}
|
| +
|
| +void RenderProcessHostMojoImpl::OnProcessLaunched() {
|
| + if (pending_handle_) {
|
| + scoped_ptr<PendingHandle> handle(pending_handle_.Pass());
|
| + SetWebUIHandle(handle->view_routing_id, handle->handle.Pass());
|
| + }
|
| +}
|
| +
|
| +
|
| +void RenderProcessHostMojoImpl::CreateMojoChannel(
|
| + base::ProcessHandle process_handle) {
|
| + if (mojo_channel_init_.get())
|
| + return;
|
| +
|
| + mojo::embedder::PlatformChannelPair channel_pair;
|
| + mojo_channel_init_.reset(new MojoChannelInit);
|
| + mojo_channel_init_->Init(
|
| + PlatformFileFromScopedPlatformHandle(channel_pair.PassServerHandle()),
|
| + BrowserThread::GetMessageLoopProxyForThread(BrowserThread::IO));
|
| + if (!mojo_channel_init_->is_handle_valid())
|
| + return;
|
| + base::PlatformFile client_file =
|
| + PlatformFileFromScopedPlatformHandle(channel_pair.PassClientHandle());
|
| + host_->Send(new MojoMsg_ChannelCreated(
|
| + IPC::GetFileHandleForProcess(client_file, process_handle,
|
| + true)));
|
| + ScopedRenderProcessMojoHandle render_process_handle(
|
| + RenderProcessMojoHandle(
|
| + mojo_channel_init_->bootstrap_message_pipe().release().value()));
|
| + render_process_mojo_.reset(render_process_handle.Pass(), this);
|
| +}
|
| +
|
| +} // namespace content
|
|
|