Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(820)

Unified Diff: mojo/common/channel_init.cc

Issue 346633002: Move channel_init out of mojo_common. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Fix gn build Created 6 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: mojo/common/channel_init.cc
diff --git a/mojo/common/channel_init.cc b/mojo/common/channel_init.cc
deleted file mode 100644
index 7eef2aec705d47c8b6f07e79b521fbb43c359b2b..0000000000000000000000000000000000000000
--- a/mojo/common/channel_init.cc
+++ /dev/null
@@ -1,59 +0,0 @@
-// 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/common/channel_init.h"
-
-#include "base/bind.h"
-#include "base/message_loop/message_loop.h"
-#include "mojo/embedder/embedder.h"
-
-namespace mojo {
-namespace common {
-
-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 common
-} // namespace mojo

Powered by Google App Engine
This is Rietveld 408576698