Delete IPC::ChannelPosix, IPC::ChannelWin and IPC::AttachmentBroker.

blimp/test/fake_engine/fake_engine_app_tests.cc

 // Copyright 2016 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 "blimp/test/fake_engine/fake_engine.h"
 
 #include <fcntl.h>
+#include <sys/socket.h>
+#include <sys/un.h>
 
 #include "base/command_line.h"
 #include "base/files/file_path.h"
 #include "base/files/file_util.h"
 #include "base/synchronization/waitable_event.h"
 #include "base/test/launcher/unit_test_launcher.h"
 #include "base/test/test_suite.h"
 #include "blimp/test/fake_engine/proto/engine.grpc.pb.h"
 #include "blimp/test/fake_engine/proto/lifetime.grpc.pb.h"
 #include "blimp/test/fake_engine/proto/logging.grpc.pb.h"
-#include "ipc/ipc_channel.h"
 #include "testing/gmock/include/gmock/gmock.h"
 #include "testing/gtest/include/gtest/gtest.h"
 #include "third_party/grpc/include/grpc++/create_channel_posix.h"
 #include "third_party/grpc/include/grpc++/grpc++.h"
 #include "third_party/grpc/include/grpc++/server_posix.h"
 
 using ::testing::_;
 
 namespace blimp {
 
 namespace {
 
+bool SocketPair(int* fd1, int* fd2) {
+  int pipe_fds[2];
+  if (socketpair(AF_UNIX, SOCK_STREAM, 0, pipe_fds) != 0) {
+    PLOG(ERROR) << "socketpair()";
+    return false;
+  }
+
+  // Set both ends to be non-blocking.
+  if (fcntl(pipe_fds[0], F_SETFL, O_NONBLOCK) == -1 ||
+      fcntl(pipe_fds[1], F_SETFL, O_NONBLOCK) == -1) {
+    PLOG(ERROR) << "fcntl(O_NONBLOCK)";
+    if (IGNORE_EINTR(close(pipe_fds[0])) < 0)
+      PLOG(ERROR) << "close";
+    if (IGNORE_EINTR(close(pipe_fds[1])) < 0)
+      PLOG(ERROR) << "close";
+    return false;
+  }
+
+  *fd1 = pipe_fds[0];
+  *fd2 = pipe_fds[1];
+
+  return true;
+}
+
 class MockLifetimeService : public Lifetime::Service {
  public:
   MOCK_METHOD3(EngineReady, grpc::Status(
       grpc::ServerContext*, const EngineReadyRequest*, EngineReadyResponse*));
 };
 
 class MockLoggingService : public Logging::Service {
  public:
   MOCK_METHOD3(Log, grpc::Status(
       grpc::ServerContext*, const LogRequest*, LogResponse*));
 };
 
 // The FakeEngineAppTest suite sets up a simple interface resembling the
 // Service, which is required by the Fake Engine. This allows testing whether
 // the Fake Engine serves its purpose of simulating the real Engine as spawned
 // by the Service.
 class FakeEngineAppTest : public testing::Test {
  public:
   FakeEngineAppTest()
       : engine_ready_(base::WaitableEvent::ResetPolicy::MANUAL,
                       base::WaitableEvent::InitialState::NOT_SIGNALED) {}
 
  protected:
   void SetUp() override {
-    CHECK(IPC::SocketPair(&rendering_server_connect_fd_, &engine_listen_fd_));
-    CHECK(IPC::SocketPair(&rendering_server_listen_fd_, &engine_connect_fd_));
+    CHECK(SocketPair(&rendering_server_connect_fd_, &engine_listen_fd_));
+    CHECK(SocketPair(&rendering_server_listen_fd_, &engine_connect_fd_));
 
     grpc::ServerBuilder builder;
     builder.RegisterService(&mock_lifetime_service_);
     builder.RegisterService(&mock_logging_service_);
     grpc_server_ = builder.BuildAndStart();
 
     // TODO(xyzzyz): Remove fcntl when https://github.com/grpc/grpc/pull/8051 is
     // merged and added to Chromium.
     int flags = fcntl(rendering_server_listen_fd_, F_GETFL, 0);
     CHECK_EQ(0, fcntl(rendering_server_listen_fd_, F_SETFL,
@@ skipping 113 matching lines @@
 }  // namespace
 
 }  // namespace blimp
 
 int main(int argc, char** argv) {
   blimp::FakeEngineTestSuite test_suite(argc, argv);
   return base::LaunchUnitTests(
       argc, argv,
       base::Bind(&base::TestSuite::Run, base::Unretained(&test_suite)));
 }