1 files changed, 59 insertions, 0 deletions
diff --git a/chromium/mojo/embedder/channel_init.cc b/chromium/mojo/embedder/channel_init.cc
new file mode 100644
index 00000000000..136a5389817
--- /dev/null
+++ b/chromium/mojo/embedder/channel_init.cc
@@ -0,0 +1,59 @@
+// 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 "mojo/embedder/channel_init.h"
+
+#include "base/bind.h"
+#include "base/message_loop/message_loop.h"
+#include "mojo/embedder/embedder.h"
+
+namespace mojo {
+namespace embedder {
+
+ChannelInit::ChannelInit()
+    : channel_info_(NULL),
+      weak_factory_(this) {
+}
+
+ChannelInit::~ChannelInit() {
+  if (channel_info_) {
+    io_thread_task_runner_->PostTask(
+        FROM_HERE,
+        base::Bind(&mojo::embedder::DestroyChannelOnIOThread, channel_info_));
+  }
+}
+
+mojo::ScopedMessagePipeHandle ChannelInit::Init(
+    base::PlatformFile file,
+    scoped_refptr<base::TaskRunner> io_thread_task_runner) {
+  DCHECK(!io_thread_task_runner_.get());  // Should only init once.
+  io_thread_task_runner_ = io_thread_task_runner;
+  mojo::ScopedMessagePipeHandle message_pipe = mojo::embedder::CreateChannel(
+      mojo::embedder::ScopedPlatformHandle(
+          mojo::embedder::PlatformHandle(file)),
+      io_thread_task_runner,
+      base::Bind(&ChannelInit::OnCreatedChannel, weak_factory_.GetWeakPtr(),
+                 io_thread_task_runner),
+      base::MessageLoop::current()->message_loop_proxy()).Pass();
+  return message_pipe.Pass();
+}
+
+// static
+void ChannelInit::OnCreatedChannel(
+    base::WeakPtr<ChannelInit> host,
+    scoped_refptr<base::TaskRunner> io_thread,
+    embedder::ChannelInfo* channel) {
+  // By the time we get here |host| may have been destroyed. If so, shutdown the
+  // channel.
+  if (!host.get()) {
+    io_thread->PostTask(
+        FROM_HERE,
+        base::Bind(&mojo::embedder::DestroyChannelOnIOThread, channel));
+    return;
+  }
+  host->channel_info_ = channel;
+}
+
+}  // namespace embedder
+}  // namespace mojo