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

mojo/system/raw_channel_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): Factor out the remaining POSIX-specific bits of this test (once we
 // have a non-POSIX implementation).
 
 #include "mojo/system/raw_channel.h"
 
 #include <fcntl.h>
 #include <stdint.h>
 #include <unistd.h>
 
 #include <vector>
 
 #include "base/basictypes.h"
 #include "base/bind.h"
-#include "base/callback.h"
 #include "base/compiler_specific.h"
 #include "base/location.h"
 #include "base/logging.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/memory/scoped_vector.h"
 #include "base/message_loop/message_loop.h"
 #include "base/posix/eintr_wrapper.h"
 #include "base/rand_util.h"
 #include "base/synchronization/lock.h"
 #include "base/synchronization/waitable_event.h"
 #include "base/threading/platform_thread.h"  // For |Sleep()|.
 #include "base/threading/simple_thread.h"
-#include "base/threading/thread.h"
 #include "base/time/time.h"
 #include "mojo/system/message_in_transit.h"
 #include "mojo/system/platform_channel_pair.h"
 #include "mojo/system/platform_handle.h"
 #include "mojo/system/scoped_platform_handle.h"
 #include "mojo/system/test_utils.h"
-#include "testing/gtest/include/gtest/gtest.h"
 
 namespace mojo {
 namespace system {
 namespace {
 
 MessageInTransit* MakeTestMessage(uint32_t num_bytes) {
   std::vector<unsigned char> bytes(num_bytes, 0);
   for (size_t i = 0; i < num_bytes; i++)
     bytes[i] = static_cast<unsigned char>(i + num_bytes);
   return MessageInTransit::Create(
@@ skipping 10 matching lines @@
   }
   return true;
 }
 
 void InitOnIOThread(RawChannel* raw_channel) {
   CHECK(raw_channel->Init());
 }
 
 // -----------------------------------------------------------------------------
 
-class RawChannelPosixTest : public testing::Test {
+class RawChannelPosixTest : public test::TestWithIOThreadBase {
  public:
-  RawChannelPosixTest() : io_thread_("io_thread") {
-  }
-
-  virtual ~RawChannelPosixTest() {
-  }
+  RawChannelPosixTest() {}
+  virtual ~RawChannelPosixTest() {}
 
   virtual void SetUp() OVERRIDE {
-    io_thread_.StartWithOptions(
-        base::Thread::Options(base::MessageLoop::TYPE_IO, 0));
+    test::TestWithIOThreadBase::SetUp();
 
     PlatformChannelPair channel_pair;
     handles[0] = channel_pair.PassServerHandle();
     handles[1] = channel_pair.PassClientHandle();
   }
 
   virtual void TearDown() OVERRIDE {
     handles[0].reset();
     handles[1].reset();
 
-    io_thread_.Stop();
+    test::TestWithIOThreadBase::TearDown();
   }
 
  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();
-  }
-
   ScopedPlatformHandle handles[2];
 
  private:
-  base::Thread io_thread_;
-
   DISALLOW_COPY_AND_ASSIGN(RawChannelPosixTest);
 };
 
 // RawChannelPosixTest.WriteMessage --------------------------------------------
 
 class WriteOnlyRawChannelDelegate : public RawChannel::Delegate {
  public:
   WriteOnlyRawChannelDelegate() {}
   virtual ~WriteOnlyRawChannelDelegate() {}
 
@@ skipping 395 matching lines @@
 
   // TODO(vtl): In theory, it's conceivable that closing the other end might
   // lead to read failing. In practice, it doesn't seem to.
   EXPECT_EQ(RawChannel::Delegate::FATAL_ERROR_FAILED_WRITE,
             delegate.WaitForFatalError());
 
   test::PostTaskAndWait(io_thread_task_runner(),
                         FROM_HERE,
                         base::Bind(&RawChannel::Shutdown,
                                    base::Unretained(rc.get())));
-
 }
 
 // RawChannelPosixTest.WriteMessageAfterShutdown -------------------------------
 
 // Makes sure that calling |WriteMessage()| after |Shutdown()| behaves
 // correctly.
 TEST_F(RawChannelPosixTest, WriteMessageAfterShutdown) {
   WriteOnlyRawChannelDelegate delegate;
   scoped_ptr<RawChannel> rc(RawChannel::Create(handles[0].Pass(),
                                                &delegate,
                                                io_thread_message_loop()));
 
   test::PostTaskAndWait(io_thread_task_runner(),
                         FROM_HERE,
                         base::Bind(&InitOnIOThread, rc.get()));
   test::PostTaskAndWait(io_thread_task_runner(),
                         FROM_HERE,
                         base::Bind(&RawChannel::Shutdown,
                                    base::Unretained(rc.get())));
 
   EXPECT_FALSE(rc->WriteMessage(MakeTestMessage(1)));
 }
 
 }  // namespace
 }  // namespace system
 }  // namespace mojo