Introduce ChannelMojo

ipc/ipc_test_base.h

 // Copyright (c) 2011 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.
 
 #ifndef IPC_IPC_TEST_BASE_H_
 #define IPC_IPC_TEST_BASE_H_
 
 #include <string>
 
 #include "base/basictypes.h"
@@ skipping 29 matching lines @@
   void Init(const std::string& test_client_name);
 
   // Creates a channel with the given listener and connects to the channel
   // (returning true if successful), respectively. Use these to use a channel
   // directly. Since the listener must outlive the channel, you must destroy the
   // channel before the listener gets destroyed.
   void CreateChannel(IPC::Listener* listener);
   bool ConnectChannel();
   void DestroyChannel();
 
+  // Releases or replaces existing channel.
+  // These are useful for testing specific types of channel subclasses.
+  scoped_ptr<IPC::Channel> ReleaseChannel();
+  void SetChannel(scoped_ptr<IPC::Channel> channel);
+
   // Use this instead of CreateChannel() if you want to use some different
   // channel specification (then use ConnectChannel() as usual).
   void CreateChannelFromChannelHandle(const IPC::ChannelHandle& channel_handle,
                                       IPC::Listener* listener);
 
   // Creates a channel proxy with the given listener and task runner. (The
   // channel proxy will automatically create and connect a channel.) You must
   // (manually) destroy the channel proxy before the task runner's thread is
   // destroyed.
   void CreateChannelProxy(IPC::Listener* listener,
@@ skipping 14 matching lines @@
   // channel or a proxy).
   IPC::Sender* sender() {
     return channel_.get() ? static_cast<IPC::Sender*>(channel_.get()) :
                             static_cast<IPC::Sender*>(channel_proxy_.get());
   }
 
   IPC::Channel* channel() { return channel_.get(); }
   IPC::ChannelProxy* channel_proxy() { return channel_proxy_.get(); }
 
   const base::ProcessHandle& client_process() const { return client_process_; }
+  scoped_refptr<base::TaskRunner> io_thread_task_runner();
 
  private:
   std::string test_client_name_;
   scoped_ptr<base::MessageLoopForIO> message_loop_;
 
   scoped_ptr<IPC::Channel> channel_;
   scoped_ptr<IPC::ChannelProxy> channel_proxy_;
 
   base::ProcessHandle client_process_;
 
   DISALLOW_COPY_AND_ASSIGN(IPCTestBase);
 };
 
 // Use this to declare the client side for tests using IPCTestBase.
 #define MULTIPROCESS_IPC_TEST_CLIENT_MAIN(test_client_name) \
     MULTIPROCESS_IPC_TEST_MAIN(test_client_name ## TestClientMain)
 
 #endif  // IPC_IPC_TEST_BASE_H_