Introduce ChannelMojo

ipc/ipc_test_base.cc

 // Copyright (c) 2012 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 "build/build_config.h"
 
 #include "ipc/ipc_test_base.h"
 
 #include "base/command_line.h"
 #include "base/process/kill.h"
@@ skipping 41 matching lines @@
 void IPCTestBase::CreateChannel(IPC::Listener* listener) {
   return CreateChannelFromChannelHandle(GetChannelName(test_client_name_),
                                         listener);
 }
 
 bool IPCTestBase::ConnectChannel() {
   CHECK(channel_.get());
   return channel_->Connect();
 }
 
+scoped_ptr<IPC::Channel> IPCTestBase::ReleaseChannel() {
+  return channel_.Pass();
+}
+
+void IPCTestBase::SetChannel(scoped_ptr<IPC::Channel> channel) {
+  channel_ = channel.Pass();
+}
+
+
 void IPCTestBase::DestroyChannel() {
   DCHECK(channel_.get());
   channel_.reset();
 }
 
 void IPCTestBase::CreateChannelFromChannelHandle(
     const IPC::ChannelHandle& channel_handle,
     IPC::Listener* listener) {
   CHECK(!channel_.get());
   CHECK(!channel_proxy_.get());
@@ skipping 41 matching lines @@
 
 bool IPCTestBase::WaitForClientShutdown() {
   DCHECK(client_process_ != base::kNullProcessHandle);
 
   bool rv = base::WaitForSingleProcess(client_process_,
                                        base::TimeDelta::FromSeconds(5));
   base::CloseProcessHandle(client_process_);
   client_process_ = base::kNullProcessHandle;
   return rv;
 }
+
+scoped_refptr<base::TaskRunner> IPCTestBase::io_thread_task_runner() {
+  return message_loop_->message_loop_proxy();
+}