Fixup the flip buffer to use a regular IOBuffer...

net/flip/flip_session.cc

 // Copyright (c) 2009 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 "net/flip/flip_session.h"
 
 #include "base/basictypes.h"
 #include "base/logging.h"
 #include "base/message_loop.h"
 #include "base/rand_util.h"
@@ skipping 78 matching lines @@
           connect_callback_(this, &FlipSession::OnSocketConnect)),
       ALLOW_THIS_IN_INITIALIZER_LIST(
           read_callback_(this, &FlipSession::OnReadComplete)),
       ALLOW_THIS_IN_INITIALIZER_LIST(
           write_callback_(this, &FlipSession::OnWriteComplete)),
       domain_(host),
       session_(session),
       connection_started_(false),
       delayed_write_pending_(false),
       write_pending_(false),
-      read_buffer_(new net::MovableIOBuffer(kReadBufferSize)),
-      read_buffer_bytes_read_(0),
+      read_buffer_(new IOBuffer(kReadBufferSize)),
       read_pending_(false),
       stream_hi_water_mark_(0) {
   // Always start at 1 for the first stream id.
   // TODO(mbelshe): consider randomization.
   stream_hi_water_mark_ = 1;
 
   flip_framer_.set_visitor(this);
 }
 
 FlipSession::~FlipSession() {
@@ skipping 247 matching lines @@
   // Write more data.  We're already in a continuation, so we can
   // go ahead and write it immediately (without going back to the
   // message loop).
   WriteSocketLater();
 }
 
 void FlipSession::ReadSocket() {
   if (read_pending_)
     return;
 
-  size_t max_bytes = kReadBufferSize;
-  read_buffer_->set_data(read_buffer_bytes_read_);
-  max_bytes -= read_buffer_bytes_read_;
-  int bytes_read = connection_.socket()->Read(read_buffer_.get(), max_bytes,
+  int bytes_read = connection_.socket()->Read(read_buffer_.get(),
+                                              kReadBufferSize,
                                               &read_callback_);
   switch (bytes_read) {
     case 0:
       // Socket is closed!
       // TODO(mbelshe): Need to abort any active streams here.
       DCHECK(!active_streams_.size());
       return;
     case net::ERR_IO_PENDING:
       // Waiting for data.  Nothing to do now.
       read_pending_ = true;
@@ skipping 371 matching lines @@
   return false;
 }
 
 void FlipStreamImpl::OnAbort() {
   if (delegate_)
     delegate_->OnClose(net::ERR_ABORTED);
 }
 
 }  // namespace net