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

ipc/mojo/scoped_ipc_support.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 "ipc/mojo/scoped_ipc_support.h"
 
 #include "base/bind.h"
 #include "base/lazy_instance.h"
 #include "base/logging.h"
 #include "base/message_loop/message_loop.h"
 #include "base/synchronization/condition_variable.h"
 #include "base/synchronization/lock.h"
 #include "base/synchronization/waitable_event.h"
 #include "base/thread_task_runner_handle.h"
+
+#if defined(USE_CHROME_EDK)
+#include "mojo/edk/embedder/embedder.h"
+#include "mojo/edk/embedder/process_delegate.h"
+#else
 #include "third_party/mojo/src/mojo/edk/embedder/embedder.h"
 #include "third_party/mojo/src/mojo/edk/embedder/process_delegate.h"
+#endif
 
 namespace IPC {
 
 namespace {
-
+#if defined(USE_CHROME_EDK)
+class IPCSupportInitializer : public mojo::edk::ProcessDelegate {
+#else
 class IPCSupportInitializer : public mojo::embedder::ProcessDelegate {
+#endif
  public:
   IPCSupportInitializer()
       : init_count_(0),
         shutting_down_(false),
         was_shut_down_(false),
         observer_(nullptr) {}
 
   ~IPCSupportInitializer() override { DCHECK(!observer_); }
 
   void Init(scoped_refptr<base::TaskRunner> io_thread_task_runner);
@@ skipping 65 matching lines @@
     return;
   }
 
   init_count_++;
   if (init_count_ == 1) {
     was_shut_down_ = false;
     observer_ = new MessageLoopObserver(this);
     io_thread_task_runner_ = io_thread_task_runner;
     io_thread_task_runner_->PostTask(
         FROM_HERE, base::Bind(&WatchMessageLoopOnIOThread, observer_));
+
+#if defined(USE_CHROME_EDK)
+    mojo::edk::InitIPCSupport(
+        io_thread_task_runner_, this, io_thread_task_runner_,
+        mojo::edk::ScopedPlatformHandle());
+#else
     mojo::embedder::InitIPCSupport(
-        mojo::embedder::ProcessType::NONE, io_thread_task_runner_, this,
-        io_thread_task_runner_, mojo::embedder::ScopedPlatformHandle());
+        mojo::embedder::ProcessType::NONE, io_thread_task_runner_, this, io_thread_task_runner_,
+        mojo::embedder::ScopedPlatformHandle());
+#endif
   }
 }
 
 void IPCSupportInitializer::ShutDown() {
   {
     base::AutoLock locker(lock_);
     if (shutting_down_ || was_shut_down_)
       return;
     DCHECK(init_count_ > 0);
     if (init_count_ > 1) {
@@ skipping 16 matching lines @@
   } else {
     io_thread_task_runner_->PostTask(
         FROM_HERE, base::Bind(&IPCSupportInitializer::ShutDownOnIOThread,
                               base::Unretained(this)));
   }
 }
 
 void IPCSupportInitializer::ShutDownOnIOThread() {
   base::AutoLock locker(lock_);
   if (shutting_down_ && !was_shut_down_) {
+#if defined(USE_CHROME_EDK)
+    mojo::edk::ShutdownIPCSupportOnIOThread();
+#else
     mojo::embedder::ShutdownIPCSupportOnIOThread();
+#endif
     init_count_ = 0;
     shutting_down_ = false;
     io_thread_task_runner_ = nullptr;
     was_shut_down_ = true;
     if (observer_) {
       delete observer_;
       observer_ = nullptr;
     }
   }
 }
@@ skipping 11 matching lines @@
 ScopedIPCSupport::ScopedIPCSupport(
     scoped_refptr<base::TaskRunner> io_thread_task_runner) {
   ipc_support_initializer.Get().Init(io_thread_task_runner);
 }
 
 ScopedIPCSupport::~ScopedIPCSupport() {
   ipc_support_initializer.Get().ShutDown();
 }
 
 }  // namespace IPC