Mojo: Add the ability to hook up a channel to the embedder API.

mojo/system/remote_message_pipe_posix_unittest.cc

 // Copyright 2013 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.
 
 // TODO(vtl): The POSIX-specific bits have been factored out. Apply this test to
 // non-POSIX once we have a non-POSIX implementation.
 
 #include <stdint.h>
 #include <string.h>
 
 #include "base/basictypes.h"
 #include "base/bind.h"
-#include "base/callback.h"
 #include "base/location.h"
 #include "base/logging.h"
 #include "base/message_loop/message_loop.h"
 #include "base/threading/thread.h"
 #include "mojo/system/channel.h"
 #include "mojo/system/local_message_pipe_endpoint.h"
 #include "mojo/system/message_pipe.h"
 #include "mojo/system/platform_channel_pair.h"
 #include "mojo/system/proxy_message_pipe_endpoint.h"
 #include "mojo/system/scoped_platform_handle.h"
 #include "mojo/system/test_utils.h"
 #include "mojo/system/waiter.h"
-#include "testing/gtest/include/gtest/gtest.h"
 
 namespace mojo {
 namespace system {
 namespace {
 
-class RemoteMessagePipeTest : public testing::Test {
+class RemoteMessagePipeTest : public test::TestWithIOThreadBase {
  public:
-  RemoteMessagePipeTest() : io_thread_("io_thread") {
-  }
-
-  virtual ~RemoteMessagePipeTest() {
-  }
+  RemoteMessagePipeTest() {}
+  virtual ~RemoteMessagePipeTest() {}
 
   virtual void SetUp() OVERRIDE {
-    io_thread_.StartWithOptions(
-        base::Thread::Options(base::MessageLoop::TYPE_IO, 0));
-
+    test::TestWithIOThreadBase::SetUp();
     test::PostTaskAndWait(io_thread_task_runner(),
                           FROM_HERE,
                           base::Bind(&RemoteMessagePipeTest::SetUpOnIOThread,
                                      base::Unretained(this)));
   }
 
   virtual void TearDown() OVERRIDE {
     test::PostTaskAndWait(io_thread_task_runner(),
                           FROM_HERE,
                           base::Bind(&RemoteMessagePipeTest::TearDownOnIOThread,
                                      base::Unretained(this)));
-    io_thread_.Stop();
+    test::TestWithIOThreadBase::TearDown();
   }
 
   // This connects MP 0, port 1 and MP 1, port 0 (leaving MP 0, port 0 and MP 1,
   // port 1 as the user-visible endpoints) to channel 0 and 1, respectively. MP
   // 0, port 1 and MP 1, port 0 must have |ProxyMessagePipeEndpoint|s.
   void ConnectMessagePipes(scoped_refptr<MessagePipe> mp_0,
                            scoped_refptr<MessagePipe> mp_1) {
     test::PostTaskAndWait(
         io_thread_task_runner(),
         FROM_HERE,
         base::Bind(&RemoteMessagePipeTest::ConnectMessagePipesOnIOThread,
                    base::Unretained(this), mp_0, mp_1));
   }
 
   // This connects |mp|'s port |channel_index ^ 1| to channel |channel_index|.
   // It assumes/requires that this is the bootstrap case, i.e., that the
   // endpoint IDs are both/will both be |Channel::kBootstrapEndpointId|. This
   // returns *without* waiting for it to finish connecting.
   void BootstrapMessagePipeNoWait(unsigned channel_index,
                                   scoped_refptr<MessagePipe> mp) {
     io_thread_task_runner()->PostTask(
         FROM_HERE,
         base::Bind(&RemoteMessagePipeTest::BootstrapMessagePipeOnIOThread,
                    base::Unretained(this), channel_index, mp));
   }
 
- protected:
-  base::MessageLoop* io_thread_message_loop() {
-    return io_thread_.message_loop();
-  }
-
-  scoped_refptr<base::TaskRunner> io_thread_task_runner() {
-    return io_thread_message_loop()->message_loop_proxy();
-  }
-
  private:
   void SetUpOnIOThread() {
     CHECK_EQ(base::MessageLoop::current(), io_thread_message_loop());
 
     PlatformChannelPair channel_pair;
     platform_handles_[0] = channel_pair.PassServerHandle();
     platform_handles_[1] = channel_pair.PassClientHandle();
   }
 
   void CreateAndInitChannel(unsigned channel_index) {
@@ skipping 43 matching lines @@
     if (channels_[0].get()) {
       channels_[0]->Shutdown();
       channels_[0] = NULL;
     }
     if (channels_[1].get()) {
       channels_[1]->Shutdown();
       channels_[1] = NULL;
     }
   }
 
-  base::Thread io_thread_;
   ScopedPlatformHandle platform_handles_[2];
   scoped_refptr<Channel> channels_[2];
 
   DISALLOW_COPY_AND_ASSIGN(RemoteMessagePipeTest);
 };
 
 TEST_F(RemoteMessagePipeTest, Basic) {
   const char hello[] = "hello";
   const char world[] = "world!!!1!!!1!";
   char buffer[100] = { 0 };
@@ skipping 252 matching lines @@
                               MOJO_READ_MESSAGE_FLAG_NONE));
   EXPECT_EQ(sizeof(hello), static_cast<size_t>(buffer_size));
   EXPECT_EQ(0, strcmp(buffer, hello));
 
   // And MP 1, port 1.
   mp_1->Close(1);
 }
 }  // namespace
 }  // namespace system
 }  // namespace mojo