Cleanup: Remove internal two-phase data pipe all-or-none support.

mojo/edk/system/remote_producer_data_pipe_impl.cc

 // Copyright 2015 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/remote_producer_data_pipe_impl.h"
 
 #include <string.h>
 
 #include <algorithm>
 #include <memory>
@@ skipping 115 matching lines @@
     UserPointer<const void> /*elements*/,
     UserPointer<uint32_t> /*num_bytes*/,
     uint32_t /*max_num_bytes_to_write*/,
     uint32_t /*min_num_bytes_to_write*/) {
   NOTREACHED();
   return MOJO_RESULT_INTERNAL;
 }
 
 MojoResult RemoteProducerDataPipeImpl::ProducerBeginWriteData(
     UserPointer<void*> /*buffer*/,
-    UserPointer<uint32_t> /*buffer_num_bytes*/,
-    uint32_t /*min_num_bytes_to_write*/) {
+    UserPointer<uint32_t> /*buffer_num_bytes*/) {
   NOTREACHED();
   return MOJO_RESULT_INTERNAL;
 }
 
 MojoResult RemoteProducerDataPipeImpl::ProducerEndWriteData(
     uint32_t /*num_bytes_written*/) {
   NOTREACHED();
   return MOJO_RESULT_INTERNAL;
 }
 
@@ skipping 95 matching lines @@
 
 MojoResult RemoteProducerDataPipeImpl::ConsumerQueryData(
     UserPointer<uint32_t> num_bytes) {
   // Note: This cast is safe, since the capacity fits into a |uint32_t|.
   num_bytes.Put(static_cast<uint32_t>(current_num_bytes_));
   return MOJO_RESULT_OK;
 }
 
 MojoResult RemoteProducerDataPipeImpl::ConsumerBeginReadData(
     UserPointer<const void*> buffer,
-    UserPointer<uint32_t> buffer_num_bytes,
-    uint32_t min_num_bytes_to_read) {
+    UserPointer<uint32_t> buffer_num_bytes) {
   size_t max_num_bytes_to_read = GetMaxNumBytesToRead();
-  if (min_num_bytes_to_read > max_num_bytes_to_read) {
-    // Don't return "should wait" since you can't wait for a specified amount of
-    // data.
-    return producer_open() ? MOJO_RESULT_OUT_OF_RANGE
-                           : MOJO_RESULT_FAILED_PRECONDITION;
-  }
-
   // Don't go into a two-phase read if there's no data.
   if (max_num_bytes_to_read == 0) {
     return producer_open() ? MOJO_RESULT_SHOULD_WAIT
                            : MOJO_RESULT_FAILED_PRECONDITION;
   }
 
   buffer.Put(buffer_.get() + start_index_);
   buffer_num_bytes.Put(static_cast<uint32_t>(max_num_bytes_to_read));
   set_consumer_two_phase_max_num_bytes_read(
       static_cast<uint32_t>(max_num_bytes_to_read));
@@ skipping 194 matching lines @@
   // If the consumer is still open and we still have data, we have to keep the
   // buffer around. Currently, we won't free it even if it empties later. (We
   // could do this -- requiring a check on every read -- but that seems to be
   // optimizing for the uncommon case.)
   if (!consumer_open() || !current_num_bytes_)
     DestroyBuffer();
 }
 
 }  // namespace system
 }  // namespace mojo