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

mojo/edk/system/remote_consumer_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_consumer_data_pipe_impl.h"
 
 #include <string.h>
 
 #include <algorithm>
 #include <memory>
@@ skipping 159 matching lines @@
   // TODO(vtl): We report |num_bytes_to_write|, instead of |offset|, even if we
   // failed at some point. This is consistent with the idea that writes either
   // "succeed" or "fail" (and since some bytes may have been sent, we opt for
   // "succeed"). Think about this some more.
   num_bytes.Put(static_cast<uint32_t>(num_bytes_to_write));
   return MOJO_RESULT_OK;
 }
 
 MojoResult RemoteConsumerDataPipeImpl::ProducerBeginWriteData(
     UserPointer<void*> buffer,
-    UserPointer<uint32_t> buffer_num_bytes,
-    uint32_t min_num_bytes_to_write) {
+    UserPointer<uint32_t> buffer_num_bytes) {
   DCHECK(consumer_open());
   DCHECK(channel_endpoint_);
 
   DCHECK_LE(consumer_num_bytes_, capacity_num_bytes());
   DCHECK_EQ(consumer_num_bytes_ % element_num_bytes(), 0u);
 
   size_t max_num_bytes_to_write = capacity_num_bytes() - consumer_num_bytes_;
-  if (min_num_bytes_to_write > max_num_bytes_to_write) {
-    // Don't return "should wait" since you can't wait for a specified amount
-    // of data.
-    return MOJO_RESULT_OUT_OF_RANGE;
-  }
-
   // Don't go into a two-phase write if there's no room.
   if (max_num_bytes_to_write == 0)
     return MOJO_RESULT_SHOULD_WAIT;
 
   EnsureBuffer();
   start_index_ = 0;  // We always have the full buffer.
   buffer.Put(buffer_.get());
   buffer_num_bytes.Put(static_cast<uint32_t>(max_num_bytes_to_write));
   set_producer_two_phase_max_num_bytes_written(
       static_cast<uint32_t>(max_num_bytes_to_write));
@@ skipping 131 matching lines @@
 }
 
 MojoResult RemoteConsumerDataPipeImpl::ConsumerQueryData(
     UserPointer<uint32_t> /*num_bytes*/) {
   NOTREACHED();
   return MOJO_RESULT_INTERNAL;
 }
 
 MojoResult RemoteConsumerDataPipeImpl::ConsumerBeginReadData(
     UserPointer<const void*> /*buffer*/,
-    UserPointer<uint32_t> /*buffer_num_bytes*/,
-    uint32_t /*min_num_bytes_to_read*/) {
+    UserPointer<uint32_t> /*buffer_num_bytes*/) {
   NOTREACHED();
   return MOJO_RESULT_INTERNAL;
 }
 
 MojoResult RemoteConsumerDataPipeImpl::ConsumerEndReadData(
     uint32_t /*num_bytes_read*/) {
   NOTREACHED();
   return MOJO_RESULT_INTERNAL;
 }
 
@@ skipping 70 matching lines @@
   DCHECK(channel_endpoint_);
   SetConsumerClosed();
   channel_endpoint_->DetachFromClient();
   channel_endpoint_ = nullptr;
   if (!producer_in_two_phase_write())
     DestroyBuffer();
 }
 
 }  // namespace system
 }  // namespace mojo