[SPDY] Avoid leaking bytes from the session flow control receive window

net/spdy/spdy_stream_test_util.h

 // Copyright (c) 2012 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.
 
 #ifndef NET_SPDY_SPDY_STREAM_TEST_UTIL_H_
 #define NET_SPDY_SPDY_STREAM_TEST_UTIL_H_
 
 #include "base/compiler_specific.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/strings/string_piece.h"
 #include "net/base/io_buffer.h"
 #include "net/base/test_completion_callback.h"
+#include "net/spdy/spdy_read_queue.h"
 #include "net/spdy/spdy_stream.h"
 
 namespace net {
 
 namespace test {
 
 // Delegate that calls Close() on |stream_| on OnClose. Used by tests
 // to make sure that such an action is harmless.
 class ClosingDelegate : public SpdyStream::Delegate {
  public:
@@ skipping 31 matching lines @@
                                  int status) OVERRIDE;
   virtual void OnHeadersSent() OVERRIDE;
   virtual int OnDataReceived(scoped_ptr<SpdyBuffer> buffer) OVERRIDE;
   virtual void OnDataSent(size_t bytes_sent) OVERRIDE;
   virtual void OnClose(int status) OVERRIDE;
 
   // Waits for the stream to be closed and returns the status passed
   // to OnClose().
   int WaitForClose();
 
+  // Drains all data from the underlying read queue and returns it as
+  // a string.
+  std::string TakeReceivedData();
+
   std::string GetResponseHeaderValue(const std::string& name) const;
   bool send_headers_completed() const { return send_headers_completed_; }
-  const std::string& received_data() const { return received_data_; }
   int headers_sent() const { return headers_sent_; }
   int data_sent() const { return data_sent_; }
 
  protected:
   const scoped_refptr<SpdyStream>& stream() { return stream_; }
 
  private:
   scoped_refptr<SpdyStream> stream_;
   TestCompletionCallback callback_;
   bool send_headers_completed_;
   SpdyHeaderBlock response_;
-  std::string received_data_;
+  SpdyReadQueue received_data_queue_;
   int headers_sent_;
   int data_sent_;
 };
 
 // Test delegate that sends data immediately in OnResponseReceived().
 class StreamDelegateSendImmediate : public StreamDelegateBase {
  public:
   // Both |headers| and |buf| can be NULL.
   StreamDelegateSendImmediate(const scoped_refptr<SpdyStream>& stream,
                               scoped_ptr<SpdyHeaderBlock> headers,
@@ skipping 26 matching lines @@
  private:
   scoped_refptr<DrainableIOBuffer> buf_;
   int body_data_sent_;
 };
 
 } // namespace test
 
 } // namespace net
 
 #endif // NET_SPDY_SPDY_STREAM_TEST_UTIL_H_