Index: content/common/mojo/channel_init.cc |
diff --git a/content/common/mojo/channel_init.cc b/content/common/mojo/channel_init.cc |
index 8eb156a044ee8d3379fda026bac7cc2e7f2e9fda..5249ccaf9eb490a968b9e478778acd11b8439dea 100644 |
--- a/content/common/mojo/channel_init.cc |
+++ b/content/common/mojo/channel_init.cc |
@@ -15,7 +15,6 @@ |
#include "base/task_runner.h" |
#include "base/thread_task_runner_handle.h" |
#include "mojo/edk/embedder/embedder.h" |
-#include "third_party/mojo/src/mojo/edk/embedder/embedder.h" |
namespace content { |
@@ -30,13 +29,9 @@ void CallMessagePipeCallbackOnThread( |
} // namespace |
-ChannelInit::ChannelInit() : channel_info_(nullptr), weak_factory_(this) {} |
+ChannelInit::ChannelInit() : weak_factory_(this) {} |
-ChannelInit::~ChannelInit() { |
- if (channel_info_) |
- mojo::embedder::DestroyChannel(channel_info_, |
- base::Bind(&base::DoNothing), nullptr); |
-} |
+ChannelInit::~ChannelInit() {} |
void ChannelInit::Init( |
base::PlatformFile file, |
@@ -44,46 +39,13 @@ void ChannelInit::Init( |
const base::Callback<void(mojo::ScopedMessagePipeHandle)>& callback) { |
scoped_ptr<IPC::ScopedIPCSupport> ipc_support( |
new IPC::ScopedIPCSupport(io_thread_task_runner)); |
- if (base::CommandLine::ForCurrentProcess()->HasSwitch("use-new-edk")) { |
- mojo::edk::CreateMessagePipe( |
- mojo::edk::ScopedPlatformHandle(mojo::edk::PlatformHandle(file)), |
- base::Bind(&CallMessagePipeCallbackOnThread, |
- base::Bind(&ChannelInit::OnCreateMessagePipe, |
- weak_factory_.GetWeakPtr(), |
- base::Passed(&ipc_support), |
- callback), |
- base::ThreadTaskRunnerHandle::Get())); |
- } else { |
- mojo::ScopedMessagePipeHandle message_pipe = mojo::embedder::CreateChannel( |
- mojo::embedder::ScopedPlatformHandle( |
- mojo::embedder::PlatformHandle(file)), |
- base::Bind(&ChannelInit::OnCreatedChannel, weak_factory_.GetWeakPtr(), |
- base::Passed(&ipc_support)), |
- base::ThreadTaskRunnerHandle::Get()); |
- callback.Run(std::move(message_pipe)); |
- } |
-} |
- |
-void ChannelInit::WillDestroySoon() { |
- if (channel_info_) |
- mojo::embedder::WillDestroyChannelSoon(channel_info_); |
-} |
- |
-// static |
-void ChannelInit::OnCreatedChannel( |
- base::WeakPtr<ChannelInit> self, |
- scoped_ptr<IPC::ScopedIPCSupport> ipc_support, |
- mojo::embedder::ChannelInfo* channel) { |
- // If |self| was already destroyed, shut the channel down. |
- if (!self) { |
- mojo::embedder::DestroyChannel(channel, |
- base::Bind(&base::DoNothing), nullptr); |
- return; |
- } |
- |
- DCHECK(!self->channel_info_); |
- self->channel_info_ = channel; |
- self->ipc_support_ = std::move(ipc_support); |
+ mojo::edk::CreateMessagePipe( |
+ mojo::edk::ScopedPlatformHandle(mojo::edk::PlatformHandle(file)), |
+ base::Bind(&CallMessagePipeCallbackOnThread, |
+ base::Bind(&ChannelInit::OnCreateMessagePipe, |
+ weak_factory_.GetWeakPtr(), |
+ base::Passed(&ipc_support), callback), |
+ base::ThreadTaskRunnerHandle::Get())); |
} |
void ChannelInit::OnCreateMessagePipe( |