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
11 namespace mojo {
12 namespace embedder {
13
ChannelInit()14 ChannelInit::ChannelInit()
15 : channel_info_(NULL),
16 weak_factory_(this) {
17 }
18
~ChannelInit()19 ChannelInit::~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
Init(base::PlatformFile file,scoped_refptr<base::TaskRunner> io_thread_task_runner)27 mojo::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
OnCreatedChannel(base::WeakPtr<ChannelInit> host,scoped_refptr<base::TaskRunner> io_thread,embedder::ChannelInfo * channel)43 void 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