[mojo] Implement pipe fusion API

mojo/edk/system/node_controller.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 "mojo/edk/system/node_controller.h"
 
 #include <algorithm>
 #include <limits>
 
 #include "base/bind.h"
@@ skipping 191 matching lines @@
     base::AutoLock lock(pending_port_merges_lock_);
     parent = GetParentChannel();
     if (!parent) {
       pending_port_merges_.push_back(std::make_pair(token, port));
       return;
     }
   }
   parent->RequestPortMerge(port.name(), token);
 }
 
+int NodeController::MergeLocalPorts(const ports::PortRef& port0,
+                                    const ports::PortRef& port1) {
+  int rv = node_->MergeLocalPorts(port0, port1);
+  AcceptIncomingMessages();
+  return rv;
+}
+
 scoped_refptr<PlatformSharedBuffer> NodeController::CreateSharedBuffer(
     size_t num_bytes) {
   // TODO(amistry): Fix sync broker and re-enable on OSX.
 #if defined(OS_POSIX) && !defined(OS_MACOSX)
   // Shared buffer creation failure is fatal, so always use the broker when we
   // have one. This does mean that a non-root process that has children will use
   // the broker for shared buffer creation even though that process is
   // privileged.
   if (broker_) {
     return broker_->GetSharedBuffer(num_bytes);
@@ skipping 677 matching lines @@
     shutdown_callback_.Reset();
   }
 
   DCHECK(!callback.is_null());
 
   callback.Run();
 }
 
 }  // namespace edk
 }  // namespace mojo