Add AllReadDataConsumed and AllWriteDataConsumed methods to SocketDataProvider

remoting/base/buffered_socket_writer_unittest.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 "remoting/base/buffered_socket_writer.h"
 
 #include <stdlib.h>
 
 #include "base/bind.h"
 #include "base/message_loop/message_loop.h"
@@ skipping 27 matching lines @@
                                   r);
     }
     int size = data.size();
     if (write_limit_ > 0)
       size = std::min(write_limit_, size);
     written_data_.append(data, 0, size);
     return net::MockWriteResult(async_write_ ? net::ASYNC : net::SYNCHRONOUS,
                                 size);
   }
 
+  bool AllReadDataConsumed() const override {
+    return true;
+  }
+
+  bool AllWriteDataConsumed() const override {
+    return true;
+  }
+
   void Reset() override {}
 
   std::string written_data() { return written_data_; }
 
   void set_write_limit(int limit) { write_limit_ = limit; }
   void set_async_write(bool async_write) { async_write_ = async_write; }
   void set_next_write_error(int error) { next_write_error_ = error; }
 
  private:
   std::string written_data_;
@@ skipping 159 matching lines @@
   writer_->Write(test_buffer_2_,
                  base::Bind(&BufferedSocketWriterTest::Unexpected,
                             base::Unretained(this)));
   base::RunLoop().RunUntilIdle();
   EXPECT_EQ(net::ERR_FAILED, write_error_);
   EXPECT_EQ(static_cast<size_t>(test_buffer_->size()),
             socket_data_provider_.written_data().size());
 }
 
 }  // namespace remoting