Add a Mojo EDK for Chrome that uses one OS pipe per message pipe.

mojo/edk/test/scoped_ipc_support.cc

Index: mojo/edk/test/scoped_ipc_support.cc
diff --git a/mojo/edk/test/scoped_ipc_support.cc b/mojo/edk/test/scoped_ipc_support.cc
new file mode 100644
index 0000000000000000000000000000000000000000..c252529b6c7d83c21a4c16ee638b92ee5122d598
--- /dev/null
+++ b/mojo/edk/test/scoped_ipc_support.cc
@@ -0,0 +1,59 @@
+// 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/test/scoped_ipc_support.h"
+
+#include "base/message_loop/message_loop.h"
+#include "mojo/edk/embedder/embedder.h"
+
+namespace mojo {
+namespace edk {
+namespace test {
+
+namespace internal {
+
+ScopedIPCSupportHelper::ScopedIPCSupportHelper()
+    : event_(true, false) {  // Manual reset.
+}
+
+ScopedIPCSupportHelper::~ScopedIPCSupportHelper() {
+  if (base::MessageLoop::current() &&
+      base::MessageLoop::current()->task_runner() == io_thread_task_runner_) {
+    ShutdownIPCSupportOnIOThread();
+  } else {
+    ShutdownIPCSupportAndWaitForNoChannels();
+    event_.Wait();
+  }
+}
+
+void ScopedIPCSupportHelper::Init(
+    ProcessDelegate* process_delegate,
+    scoped_refptr<base::TaskRunner> io_thread_task_runner) {
+  io_thread_task_runner_ = io_thread_task_runner;
+  // Note: Run delegate methods on the I/O thread.
+  InitIPCSupport(io_thread_task_runner_, process_delegate,
+                 io_thread_task_runner_);
+}
+
+void ScopedIPCSupportHelper::OnShutdownCompleteImpl() {
+  event_.Signal();
+}
+
+}  // namespace internal
+
+ScopedIPCSupport::ScopedIPCSupport(
+    scoped_refptr<base::TaskRunner> io_thread_task_runner) {
+  helper_.Init(this, io_thread_task_runner.Pass());
+}
+
+ScopedIPCSupport::~ScopedIPCSupport() {
+}
+
+void ScopedIPCSupport::OnShutdownComplete() {
+  helper_.OnShutdownCompleteImpl();
+}
+
+}  // namespace test
+}  // namespace edk
+}  // namespace mojo