Move //mojo/{public, edk} underneath //third_party

mojo/edk/system/channel_unittest.cc

Index: mojo/edk/system/channel_unittest.cc
diff --git a/mojo/edk/system/channel_unittest.cc b/mojo/edk/system/channel_unittest.cc
deleted file mode 100644
index e82b32191770589281dff3a3ef39baaa59fa88e0..0000000000000000000000000000000000000000
--- a/mojo/edk/system/channel_unittest.cc
+++ /dev/null
@@ -1,210 +0,0 @@
-// Copyright 2014 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 "mojo/edk/system/channel.h"
-
-#include "base/bind.h"
-#include "base/location.h"
-#include "base/message_loop/message_loop.h"
-#include "base/test/test_io_thread.h"
-#include "mojo/edk/embedder/platform_channel_pair.h"
-#include "mojo/edk/embedder/simple_platform_support.h"
-#include "mojo/edk/system/channel_endpoint.h"
-#include "mojo/edk/system/channel_endpoint_id.h"
-#include "mojo/edk/system/message_pipe.h"
-#include "mojo/edk/system/raw_channel.h"
-#include "mojo/edk/system/test_utils.h"
-#include "mojo/edk/system/waiter.h"
-#include "testing/gtest/include/gtest/gtest.h"
-
-namespace mojo {
-namespace system {
-namespace {
-
-class ChannelTest : public testing::Test {
- public:
-  ChannelTest() : io_thread_(base::TestIOThread::kAutoStart) {}
-  ~ChannelTest() override {}
-
-  void SetUp() override {
-    io_thread_.PostTaskAndWait(
-        FROM_HERE,
-        base::Bind(&ChannelTest::SetUpOnIOThread, base::Unretained(this)));
-  }
-
-  void CreateChannelOnIOThread() {
-    CHECK_EQ(base::MessageLoop::current(), io_thread()->message_loop());
-    channel_ = new Channel(&platform_support_);
-  }
-
-  void InitChannelOnIOThread() {
-    CHECK_EQ(base::MessageLoop::current(), io_thread()->message_loop());
-
-    CHECK(raw_channel_);
-    CHECK(channel_);
-    channel_->Init(raw_channel_.Pass());
-  }
-
-  void ShutdownChannelOnIOThread() {
-    CHECK_EQ(base::MessageLoop::current(), io_thread()->message_loop());
-
-    CHECK(channel_);
-    channel_->Shutdown();
-  }
-
-  base::TestIOThread* io_thread() { return &io_thread_; }
-  RawChannel* raw_channel() { return raw_channel_.get(); }
-  scoped_ptr<RawChannel>* mutable_raw_channel() { return &raw_channel_; }
-  Channel* channel() { return channel_.get(); }
-  scoped_refptr<Channel>* mutable_channel() { return &channel_; }
-
- private:
-  void SetUpOnIOThread() {
-    CHECK_EQ(base::MessageLoop::current(), io_thread()->message_loop());
-
-    embedder::PlatformChannelPair channel_pair;
-    raw_channel_ = RawChannel::Create(channel_pair.PassServerHandle()).Pass();
-    other_platform_handle_ = channel_pair.PassClientHandle();
-  }
-
-  embedder::SimplePlatformSupport platform_support_;
-  base::TestIOThread io_thread_;
-  scoped_ptr<RawChannel> raw_channel_;
-  embedder::ScopedPlatformHandle other_platform_handle_;
-  scoped_refptr<Channel> channel_;
-
-  DISALLOW_COPY_AND_ASSIGN(ChannelTest);
-};
-
-// ChannelTest.InitShutdown ----------------------------------------------------
-
-TEST_F(ChannelTest, InitShutdown) {
-  io_thread()->PostTaskAndWait(FROM_HERE,
-                               base::Bind(&ChannelTest::CreateChannelOnIOThread,
-                                          base::Unretained(this)));
-  ASSERT_TRUE(channel());
-
-  io_thread()->PostTaskAndWait(
-      FROM_HERE,
-      base::Bind(&ChannelTest::InitChannelOnIOThread, base::Unretained(this)));
-
-  io_thread()->PostTaskAndWait(
-      FROM_HERE, base::Bind(&ChannelTest::ShutdownChannelOnIOThread,
-                            base::Unretained(this)));
-
-  // Okay to destroy |Channel| on not-the-I/O-thread.
-  EXPECT_TRUE(channel()->HasOneRef());
-  *mutable_channel() = nullptr;
-}
-
-// ChannelTest.CloseBeforeAttachAndRun -----------------------------------------
-
-TEST_F(ChannelTest, CloseBeforeRun) {
-  io_thread()->PostTaskAndWait(FROM_HERE,
-                               base::Bind(&ChannelTest::CreateChannelOnIOThread,
-                                          base::Unretained(this)));
-  ASSERT_TRUE(channel());
-
-  io_thread()->PostTaskAndWait(
-      FROM_HERE,
-      base::Bind(&ChannelTest::InitChannelOnIOThread, base::Unretained(this)));
-
-  scoped_refptr<ChannelEndpoint> channel_endpoint;
-  scoped_refptr<MessagePipe> mp(
-      MessagePipe::CreateLocalProxy(&channel_endpoint));
-
-  mp->Close(0);
-
-  channel()->SetBootstrapEndpoint(channel_endpoint);
-
-  io_thread()->PostTaskAndWait(
-      FROM_HERE, base::Bind(&ChannelTest::ShutdownChannelOnIOThread,
-                            base::Unretained(this)));
-
-  EXPECT_TRUE(channel()->HasOneRef());
-}
-
-// ChannelTest.ShutdownAfterAttachAndRun ---------------------------------------
-
-TEST_F(ChannelTest, ShutdownAfterAttach) {
-  io_thread()->PostTaskAndWait(FROM_HERE,
-                               base::Bind(&ChannelTest::CreateChannelOnIOThread,
-                                          base::Unretained(this)));
-  ASSERT_TRUE(channel());
-
-  io_thread()->PostTaskAndWait(
-      FROM_HERE,
-      base::Bind(&ChannelTest::InitChannelOnIOThread, base::Unretained(this)));
-
-  scoped_refptr<ChannelEndpoint> channel_endpoint;
-  scoped_refptr<MessagePipe> mp(
-      MessagePipe::CreateLocalProxy(&channel_endpoint));
-
-  channel()->SetBootstrapEndpoint(channel_endpoint);
-
-  Waiter waiter;
-  waiter.Init();
-  ASSERT_EQ(
-      MOJO_RESULT_OK,
-      mp->AddAwakable(0, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, nullptr));
-
-  // Don't wait for the shutdown to run ...
-  io_thread()->PostTask(FROM_HERE,
-                        base::Bind(&ChannelTest::ShutdownChannelOnIOThread,
-                                   base::Unretained(this)));
-
-  // ... since this |Wait()| should fail once the channel is shut down.
-  EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION,
-            waiter.Wait(MOJO_DEADLINE_INDEFINITE, nullptr));
-  HandleSignalsState hss;
-  mp->RemoveAwakable(0, &waiter, &hss);
-  EXPECT_EQ(MOJO_HANDLE_SIGNAL_PEER_CLOSED, hss.satisfied_signals);
-  EXPECT_EQ(MOJO_HANDLE_SIGNAL_PEER_CLOSED, hss.satisfiable_signals);
-
-  mp->Close(0);
-
-  EXPECT_TRUE(channel()->HasOneRef());
-}
-
-// ChannelTest.WaitAfterAttachRunAndShutdown -----------------------------------
-
-TEST_F(ChannelTest, WaitAfterAttachRunAndShutdown) {
-  io_thread()->PostTaskAndWait(FROM_HERE,
-                               base::Bind(&ChannelTest::CreateChannelOnIOThread,
-                                          base::Unretained(this)));
-  ASSERT_TRUE(channel());
-
-  io_thread()->PostTaskAndWait(
-      FROM_HERE,
-      base::Bind(&ChannelTest::InitChannelOnIOThread, base::Unretained(this)));
-
-  scoped_refptr<ChannelEndpoint> channel_endpoint;
-  scoped_refptr<MessagePipe> mp(
-      MessagePipe::CreateLocalProxy(&channel_endpoint));
-
-  channel()->SetBootstrapEndpoint(channel_endpoint);
-
-  io_thread()->PostTaskAndWait(
-      FROM_HERE, base::Bind(&ChannelTest::ShutdownChannelOnIOThread,
-                            base::Unretained(this)));
-
-  Waiter waiter;
-  waiter.Init();
-  HandleSignalsState hss;
-  EXPECT_EQ(
-      MOJO_RESULT_FAILED_PRECONDITION,
-      mp->AddAwakable(0, &waiter, MOJO_HANDLE_SIGNAL_READABLE, 123, &hss));
-  EXPECT_EQ(MOJO_HANDLE_SIGNAL_PEER_CLOSED, hss.satisfied_signals);
-  EXPECT_EQ(MOJO_HANDLE_SIGNAL_PEER_CLOSED, hss.satisfiable_signals);
-
-  mp->Close(0);
-
-  EXPECT_TRUE(channel()->HasOneRef());
-}
-
-// TODO(vtl): More. ------------------------------------------------------------
-
-}  // namespace
-}  // namespace system
-}  // namespace mojo