diff options
author | morrita <morrita@chromium.org> | 2014-09-23 14:16:00 -0700 |
---|---|---|
committer | Commit bot <commit-bot@chromium.org> | 2014-09-23 21:16:28 +0000 |
commit | 54f6f80c3623a6fb9d3049b6f5e0e23b1d76c34d (patch) | |
tree | d5188994206cd43ae680f6e7325ec5c45075b9da /ipc/mojo/ipc_channel_mojo_host.cc | |
parent | de9555146d87d2daf5e2e1da425d46b8efc06415 (diff) | |
download | chromium_src-54f6f80c3623a6fb9d3049b6f5e0e23b1d76c34d.zip chromium_src-54f6f80c3623a6fb9d3049b6f5e0e23b1d76c34d.tar.gz chromium_src-54f6f80c3623a6fb9d3049b6f5e0e23b1d76c34d.tar.bz2 |
IPC::ChannelMojo: Introduce IPC::MojoBootstrap for Windows
ChannelMojo doesn't work on Windows with existing implementaion
and this CL fixes it.
On Windows, ChannelHandle isn't immediately usable: The handle has
to be activated through ConnectNamedPipe() windows API, which is done in
its own Connect() handlshaking phase. ChannelMojo didn't Connect()
underlying channel and took the ChannelHandle over so the handle
wasn't activated.
Instead of hijacking underlying ChannelHandle, this CL actually Connect()s
underlying channel, creates a pipe on the server side, send one side of the
pipe to the client process, and use the pipe for the MessagePipe
initialization.
These initialization task is encapsulated behind new MojoBootstrap class.
ChannelMojo creates MojoBootstrap class to get the PlatformHandle which
is already activated and usable.
BUG=377980
TEST=ipc_mojo_bootstrap_unittest.cc, ipc_channel_mojo_unittest.cc
R=viettrungluu@chromium.org, darin@chromium.org, yzshen@chromium.org
Review URL: https://codereview.chromium.org/553283002
Cr-Commit-Position: refs/heads/master@{#296248}
Diffstat (limited to 'ipc/mojo/ipc_channel_mojo_host.cc')
-rw-r--r-- | ipc/mojo/ipc_channel_mojo_host.cc | 47 |
1 files changed, 47 insertions, 0 deletions
diff --git a/ipc/mojo/ipc_channel_mojo_host.cc b/ipc/mojo/ipc_channel_mojo_host.cc new file mode 100644 index 0000000..4318a15 --- /dev/null +++ b/ipc/mojo/ipc_channel_mojo_host.cc @@ -0,0 +1,47 @@ +// 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 "ipc/mojo/ipc_channel_mojo_host.h" + +#include "base/bind.h" +#include "base/message_loop/message_loop.h" +#include "ipc/mojo/ipc_channel_mojo.h" + +namespace IPC { + +ChannelMojoHost::ChannelMojoHost(scoped_refptr<base::TaskRunner> task_runner) + : weak_factory_(this), task_runner_(task_runner), channel_(NULL) { +} + +ChannelMojoHost::~ChannelMojoHost() { +} + +void ChannelMojoHost::OnClientLaunched(base::ProcessHandle process) { + if (task_runner_ == base::MessageLoop::current()->message_loop_proxy()) { + InvokeOnClientLaunched(process); + } else { + task_runner_->PostTask(FROM_HERE, + base::Bind(&ChannelMojoHost::InvokeOnClientLaunched, + weak_factory_.GetWeakPtr(), + process)); + } +} + +void ChannelMojoHost::InvokeOnClientLaunched(base::ProcessHandle process) { + if (!channel_) + return; + channel_->OnClientLaunched(process); +} + +void ChannelMojoHost::OnChannelCreated(ChannelMojo* channel) { + DCHECK(channel_ == NULL); + channel_ = channel; +} + +void ChannelMojoHost::OnChannelDestroyed() { + DCHECK(channel_ != NULL); + channel_ = NULL; +} + +} // namespace IPC |