Allow data pipe producer/consumer handles to be re-sent.

mojo/edk/system/data_pipe.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/data_pipe.h"
 
 #include <string.h>
 
 #include <algorithm>
 #include <limits>
@@ skipping 412 matching lines @@
   base::AutoLock locker(lock_);
   DCHECK(has_local_producer_no_lock());
   // Warning: After |ProducerEndSerialize()|, quite probably |impl_| has
   // changed.
   bool rv = impl_->ProducerEndSerialize(channel, destination, actual_size,
                                         platform_handles);
 
   // TODO(vtl): The code below is similar to, but not quite the same as,
   // |ProducerCloseNoLock()|.
   DCHECK(has_local_producer_no_lock());
+  producer_awakable_list_->CancelAll();
   producer_awakable_list_.reset();
   // Not a bug, except possibly in "user" code.
   DVLOG_IF(2, producer_in_two_phase_write_no_lock())
       << "Producer transferred with active two-phase write";
   producer_two_phase_max_num_bytes_written_ = 0;
+  if (!has_local_consumer_no_lock())
+    producer_open_ = false;
 
   return rv;
 }
 
 bool DataPipe::ProducerIsBusy() const {
   base::AutoLock locker(lock_);
   return producer_in_two_phase_write_no_lock();
 }
 
 void DataPipe::ConsumerCancelAllAwakables() {
@@ skipping 187 matching lines @@
     embedder::PlatformHandleVector* platform_handles) {
   base::AutoLock locker(lock_);
   DCHECK(has_local_consumer_no_lock());
   // Warning: After |ConsumerEndSerialize()|, quite probably |impl_| has
   // changed.
   bool rv = impl_->ConsumerEndSerialize(channel, destination, actual_size,
                                         platform_handles);
 
   // TODO(vtl): The code below is similar to, but not quite the same as,
   // |ConsumerCloseNoLock()|.
+  consumer_awakable_list_->CancelAll();
   consumer_awakable_list_.reset();
   // Not a bug, except possibly in "user" code.
   DVLOG_IF(2, consumer_in_two_phase_read_no_lock())
       << "Consumer transferred with active two-phase read";
   consumer_two_phase_max_num_bytes_read_ = 0;
+  if (!has_local_producer_no_lock())
+    consumer_open_ = false;
 
   return rv;
 }
 
 bool DataPipe::ConsumerIsBusy() const {
   base::AutoLock locker(lock_);
   return consumer_in_two_phase_read_no_lock();
 }
 
 DataPipe::DataPipe(bool has_local_producer,
@@ skipping 150 matching lines @@
   SetProducerClosedNoLock();
 }
 
 void DataPipe::SetConsumerClosed() {
   base::AutoLock locker(lock_);
   SetConsumerClosedNoLock();
 }
 
 }  // namespace system
 }  // namespace mojo