Move PlatformChannelPair to //mojo/edk/platform and rename it PlatformPipe.

mojo/edk/embedder/multiprocess_embedder_unittest.cc

 // Copyright 2015 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/embedder/multiprocess_embedder.h"
 
 #include <string.h>
 
 #include <memory>
 
 #include "base/logging.h"
-#include "mojo/edk/embedder/platform_channel_pair.h"
 #include "mojo/edk/embedder/test_embedder.h"
+#include "mojo/edk/platform/platform_pipe.h"
 #include "mojo/edk/system/test/test_command_line.h"
 #include "mojo/edk/system/test/test_io_thread.h"
 #include "mojo/edk/system/test/timeouts.h"
 #include "mojo/edk/test/multiprocess_test_helper.h"
 #include "mojo/edk/test/scoped_ipc_support.h"
 #include "mojo/edk/util/command_line.h"
 #include "mojo/edk/util/ref_ptr.h"
 #include "mojo/edk/util/waitable_event.h"
 #include "mojo/public/c/system/functions.h"
 #include "mojo/public/c/system/types.h"
 #include "mojo/public/cpp/system/handle.h"
 #include "mojo/public/cpp/system/macros.h"
 #include "mojo/public/cpp/system/message_pipe.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 using mojo::platform::PlatformHandleWatcher;
+using mojo::platform::PlatformPipe;
 using mojo::platform::ScopedPlatformHandle;
 using mojo::platform::TaskRunner;
 using mojo::system::test::TestIOThread;
 using mojo::util::ManualResetWaitableEvent;
 using mojo::util::RefPtr;
 
 namespace mojo {
 namespace embedder {
 namespace {
 
@@ skipping 100 matching lines @@
 
   TestIOThread test_io_thread_;
 
   MOJO_DISALLOW_COPY_AND_ASSIGN(MultiprocessEmbedderTest);
 };
 
 TEST_F(MultiprocessEmbedderTest, ChannelsBasic) {
   mojo::test::ScopedIPCSupport ipc_support(test_io_task_runner().Clone(),
                                            test_io_watcher());
 
-  PlatformChannelPair channel_pair;
+  PlatformPipe channel_pair;
   ScopedTestChannel server_channel(channel_pair.handle0.Pass());
   MojoHandle server_mp = server_channel.bootstrap_message_pipe();
   EXPECT_NE(server_mp, MOJO_HANDLE_INVALID);
   ScopedTestChannel client_channel(channel_pair.handle1.Pass());
   MojoHandle client_mp = client_channel.bootstrap_message_pipe();
   EXPECT_NE(client_mp, MOJO_HANDLE_INVALID);
 
   // We can write to a message pipe handle immediately.
   const char kHello[] = "hello";
   EXPECT_EQ(
@@ skipping 25 matching lines @@
   server_channel.WaitForChannelCreationCompletion();
   client_channel.WaitForChannelCreationCompletion();
   EXPECT_TRUE(server_channel.channel_info());
   EXPECT_TRUE(client_channel.channel_info());
 }
 
 TEST_F(MultiprocessEmbedderTest, ChannelsHandlePassing) {
   mojo::test::ScopedIPCSupport ipc_support(test_io_task_runner().Clone(),
                                            test_io_watcher());
 
-  PlatformChannelPair channel_pair;
+  PlatformPipe channel_pair;
   ScopedTestChannel server_channel(channel_pair.handle0.Pass());
   MojoHandle server_mp = server_channel.bootstrap_message_pipe();
   EXPECT_NE(server_mp, MOJO_HANDLE_INVALID);
   ScopedTestChannel client_channel(channel_pair.handle1.Pass());
   MojoHandle client_mp = client_channel.bootstrap_message_pipe();
   EXPECT_NE(client_mp, MOJO_HANDLE_INVALID);
 
   MojoHandle h0, h1;
   EXPECT_EQ(MOJO_RESULT_OK, MojoCreateMessagePipe(nullptr, &h0, &h1));
 
@@ skipping 154 matching lines @@
   test_io_thread().PostTaskAndWait(
       [channel_info]() { DestroyChannelOnIOThread(channel_info); });
 }
 
 TEST_F(MultiprocessEmbedderTest, ChannelShutdownRace_MessagePipeClose) {
   const size_t kIterations = 1000;
   mojo::test::ScopedIPCSupport ipc_support(test_io_task_runner().Clone(),
                                            test_io_watcher());
 
   for (size_t i = 0; i < kIterations; i++) {
-    PlatformChannelPair channel_pair;
+    PlatformPipe channel_pair;
     std::unique_ptr<ScopedTestChannel> server_channel(
         new ScopedTestChannel(channel_pair.handle0.Pass()));
     server_channel->WaitForChannelCreationCompletion();
     server_channel->NoWaitOnShutdown();
 
     MojoHandle server_mp = server_channel->bootstrap_message_pipe();
     EXPECT_NE(server_mp, MOJO_HANDLE_INVALID);
 
     // Race between channel shutdown and closing a message pipe. The message
     // pipe doesn't have to be the bootstrap pipe. It just has to be bound to
@@ skipping 316 matching lines @@
 
   EXPECT_TRUE(test::Shutdown());
 }
 
 // TODO(vtl): Test immediate write & close.
 // TODO(vtl): Test broken-connection cases.
 
 }  // namespace
 }  // namespace embedder
 }  // namespace mojo