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

mojo/edk/js/drain_data.cc

 // 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 "third_party/mojo/src/mojo/edk/js/drain_data.h"
+#include "mojo/edk/js/drain_data.h"
 
 #include "gin/array_buffer.h"
 #include "gin/converter.h"
 #include "gin/dictionary.h"
 #include "gin/per_context_data.h"
 #include "gin/per_isolate_data.h"
 #include "mojo/public/cpp/environment/environment.h"
 #include "mojo/public/cpp/system/core.h"
 
 namespace mojo {
-namespace js {
+namespace edk {
 
 DrainData::DrainData(v8::Isolate* isolate, mojo::Handle handle)
     : isolate_(isolate),
       handle_(DataPipeConsumerHandle(handle.value())),
       wait_id_(0) {
 
   v8::Handle<v8::Context> context(isolate_->GetCurrentContext());
   runner_ = gin::PerContextData::From(context)->runner()->GetWeakPtr();
 
   WaitForData();
 }
 
 v8::Handle<v8::Value> DrainData::GetPromise() {
   CHECK(resolver_.IsEmpty());
   v8::Handle<v8::Promise::Resolver> resolver(
       v8::Promise::Resolver::New(isolate_));
   resolver_.Reset(isolate_, resolver);
   return resolver->GetPromise();
 }
 
 DrainData::~DrainData() {
   if (wait_id_)
     Environment::GetDefaultAsyncWaiter()->CancelWait(wait_id_);
   resolver_.Reset();
 }
 
 void DrainData::WaitForData() {
   wait_id_ = Environment::GetDefaultAsyncWaiter()->AsyncWait(
-      2, handle_.get().value(), MOJO_HANDLE_SIGNAL_READABLE,
-      MOJO_DEADLINE_INDEFINITE, &DrainData::WaitCompleted, this);
+      handle_.get().value(),
+      MOJO_HANDLE_SIGNAL_READABLE,
+      MOJO_DEADLINE_INDEFINITE,
+      &DrainData::WaitCompleted,
+      this);
 }
 
 void DrainData::DataReady(MojoResult result) {
   wait_id_ = 0;
   if (result != MOJO_RESULT_OK) {
     DeliverData(result);
     return;
   }
   while (result == MOJO_RESULT_OK) {
     result = ReadData();
@@ skipping 60 matching lines @@
   v8::Handle<v8::Value> settled_value(ConvertToV8(isolate_, dictionary));
 
   if (result == MOJO_RESULT_FAILED_PRECONDITION)
     resolver->Resolve(settled_value);
   else
     resolver->Reject(settled_value);
 
   delete this;
 }
 
-}  // namespace js
+}  // namespace edk
 }  // namespace mojo