Allow data pipe producer/consumer handles to be transferred during two-phase operations.

mojo/edk/system/handle_table.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 "mojo/edk/system/handle_table.h"
 
 #include <limits>
 #include <utility>
 
 #include "base/logging.h"
@@ skipping 151 matching lines @@
                        "to transfer handle "
                     << handle_values[i]
                     << " while it is in use on a different thread";
 
       // Unset the busy flag (since it won't be unset below).
       entries[i]->busy = false;
       error_result = MOJO_RESULT_BUSY;
       break;
     }
 
-    // Check if the dispatcher is busy (e.g., in a two-phase read/write).
-    // (Note that this must be done after the dispatcher's lock is acquired.)
-    if (transport.IsBusy()) {
-      // Unset the busy flag and end the transport (since it won't be done
-      // below).
-      entries[i]->busy = false;
-      transport.End();
-      error_result = MOJO_RESULT_BUSY;
-      break;
-    }
-
     // Hang on to the transport (which we'll need to end the transport).
     (*transports)[i] = transport;
   }
   if (i < num_handles) {
     DCHECK_NE(error_result, MOJO_RESULT_INTERNAL);
 
     // Unset the busy flags and release the locks.
     for (uint32_t j = 0; j < i; j++) {
       DCHECK(entries[j]->busy);
       entries[j]->busy = false;
@@ skipping 51 matching lines @@
   for (uint32_t i = 0; i < num_handles; i++) {
     HandleToEntryMap::iterator it = handle_to_entry_map_.find(handle_values[i]);
     DCHECK(it != handle_to_entry_map_.end());
     DCHECK(it->second.busy);
     it->second.busy = false;
   }
 }
 
 }  // namespace system
 }  // namespace mojo