Add ipc_mojo_perftests

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 34 matching lines @@
     scoped_ptr<base::MessageLoop> message_loop) {
   DCHECK(!test_client_name.empty());
   DCHECK(test_client_name_.empty());
   DCHECK(!message_loop_);
 
   test_client_name_ = test_client_name;
   message_loop_ = message_loop.Pass();
 }
 
 void IPCTestBase::CreateChannel(IPC::Listener* listener) {
-  return CreateChannelFromChannelHandle(GetChannelName(test_client_name_),
-                                        listener);
+  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());
-  channel_ = IPC::Channel::CreateServer(channel_handle, listener);
+  channel_ = CreateChannelFactory(
+      channel_handle, task_runner().get())->BuildChannel(listener);
 }
 
 void IPCTestBase::CreateChannelProxy(
     IPC::Listener* listener,
     const scoped_refptr<base::SingleThreadTaskRunner>& ipc_task_runner) {
   CHECK(!channel_.get());
   CHECK(!channel_proxy_.get());
-  channel_proxy_ = IPC::ChannelProxy::Create(GetChannelName(test_client_name_),
-                                             IPC::Channel::MODE_SERVER,
-                                             listener,
-                                             ipc_task_runner);
+  channel_proxy_ = IPC::ChannelProxy::Create(
+      CreateChannelFactory(GetChannelName(test_client_name_),
+                           ipc_task_runner.get()),
+      listener,
+      ipc_task_runner);
 }
 
 void IPCTestBase::DestroyChannelProxy() {
   CHECK(channel_proxy_.get());
   channel_proxy_.reset();
 }
 
 bool IPCTestBase::StartClient() {
   DCHECK(client_process_ == base::kNullProcessHandle);
 
@@ skipping 23 matching lines @@
   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::task_runner() {
   return message_loop_->message_loop_proxy();
 }
+
+scoped_ptr<IPC::ChannelFactory> IPCTestBase::CreateChannelFactory(
+    const IPC::ChannelHandle& handle,
+    base::TaskRunner* runner) {
+  return IPC::ChannelFactory::Create(handle, IPC::Channel::MODE_SERVER);
+}