Make it possible to write a message pipe endpoint's peer into it.

mojo/edk/system/dispatcher.cc

 // Copyright 2013 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/dispatcher.h"
 
 #include "base/logging.h"
 #include "mojo/edk/system/configuration.h"
 #include "mojo/edk/system/data_pipe_consumer_dispatcher.h"
 #include "mojo/edk/system/data_pipe_producer_dispatcher.h"
@@ skipping 508 matching lines @@
 
 void Dispatcher::CloseNoLock() {
   mutex_.AssertHeld();
   DCHECK(!is_closed_);
 
   is_closed_ = true;
   CancelAllAwakablesNoLock();
   CloseImplNoLock();
 }
 
-RefPtr<Dispatcher> Dispatcher::CreateEquivalentDispatcherAndCloseNoLock() {
+RefPtr<Dispatcher> Dispatcher::CreateEquivalentDispatcherAndCloseNoLock(
+    MessagePipe* message_pipe,
+    unsigned port) {
   mutex_.AssertHeld();
   DCHECK(!is_closed_);
 
   is_closed_ = true;
-  CancelAllAwakablesNoLock();
-  return CreateEquivalentDispatcherAndCloseImplNoLock();
+  return CreateEquivalentDispatcherAndCloseImplNoLock(message_pipe, port);
 }
 
 void Dispatcher::StartSerialize(Channel* channel,
                                 size_t* max_size,
                                 size_t* max_platform_handles) {
   DCHECK(channel);
   DCHECK(max_size);
   DCHECK(max_platform_handles);
   AssertHasOneRef();  // Only one ref => no need to take the lock.
   DCHECK(!is_closed_);
@@ skipping 29 matching lines @@
 // DispatcherTransport ---------------------------------------------------------
 
 void DispatcherTransport::End() {
   DCHECK(dispatcher_);
   dispatcher_->mutex_.Unlock();
   dispatcher_ = nullptr;
 }
 
 }  // namespace system
 }  // namespace mojo