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 "mojo/embedder/channel_init.h"
6
7#include "base/bind.h"
8#include "base/message_loop/message_loop.h"
9#include "mojo/embedder/embedder.h"
10
11namespace mojo {
12namespace embedder {
13
14ChannelInit::ChannelInit()
15    : channel_info_(NULL),
16      weak_factory_(this) {
17}
18
19ChannelInit::~ChannelInit() {
20  if (channel_info_) {
21    io_thread_task_runner_->PostTask(
22        FROM_HERE,
23        base::Bind(&mojo::embedder::DestroyChannelOnIOThread, channel_info_));
24  }
25}
26
27mojo::ScopedMessagePipeHandle ChannelInit::Init(
28    base::PlatformFile file,
29    scoped_refptr<base::TaskRunner> io_thread_task_runner) {
30  DCHECK(!io_thread_task_runner_.get());  // Should only init once.
31  io_thread_task_runner_ = io_thread_task_runner;
32  mojo::ScopedMessagePipeHandle message_pipe = mojo::embedder::CreateChannel(
33      mojo::embedder::ScopedPlatformHandle(
34          mojo::embedder::PlatformHandle(file)),
35      io_thread_task_runner,
36      base::Bind(&ChannelInit::OnCreatedChannel, weak_factory_.GetWeakPtr(),
37                 io_thread_task_runner),
38      base::MessageLoop::current()->message_loop_proxy()).Pass();
39  return message_pipe.Pass();
40}
41
42// static
43void ChannelInit::OnCreatedChannel(
44    base::WeakPtr<ChannelInit> host,
45    scoped_refptr<base::TaskRunner> io_thread,
46    embedder::ChannelInfo* channel) {
47  // By the time we get here |host| may have been destroyed. If so, shutdown the
48  // channel.
49  if (!host.get()) {
50    io_thread->PostTask(
51        FROM_HERE,
52        base::Bind(&mojo::embedder::DestroyChannelOnIOThread, channel));
53    return;
54  }
55  host->channel_info_ = channel;
56}
57
58}  // namespace embedder
59}  // namespace mojo
60