diff options
author | akalin@chromium.org <akalin@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2013-04-17 10:38:43 +0000 |
---|---|---|
committer | akalin@chromium.org <akalin@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2013-04-17 10:38:43 +0000 |
commit | ca690b0ccb3684bec0a7a5ed2406346762b57ba7 (patch) | |
tree | 13e99d0ff0396e10d9fa9301b3b1c4820f448e28 /net/spdy/spdy_http_stream.h | |
parent | 988117fa7cce0514c94bfb58743b5a294ab0f1a3 (diff) | |
download | chromium_src-ca690b0ccb3684bec0a7a5ed2406346762b57ba7.zip chromium_src-ca690b0ccb3684bec0a7a5ed2406346762b57ba7.tar.gz chromium_src-ca690b0ccb3684bec0a7a5ed2406346762b57ba7.tar.bz2 |
[SPDY] Replace SpdyIOBuffer with new SpdyBuffer class
Use SpdyBuffer for both SPDY reads and writes. A future
CL will add hooks to SpdyBuffer so that we keep track of
flow control windows properly.
Replace SpdyFrameProducer with SpdyBufferProducer.
Also introduce new SpdyReadQueue class for delegates
of SpdyStream to use.
BUG=176592
Committed: https://src.chromium.org/viewvc/chrome?view=rev&revision=194560
Review URL: https://codereview.chromium.org/13990005
git-svn-id: svn://svn.chromium.org/chrome/trunk/src@194564 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'net/spdy/spdy_http_stream.h')
-rw-r--r-- | net/spdy/spdy_http_stream.h | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/net/spdy/spdy_http_stream.h b/net/spdy/spdy_http_stream.h index 226d01c..2af82f0 100644 --- a/net/spdy/spdy_http_stream.h +++ b/net/spdy/spdy_http_stream.h @@ -13,6 +13,7 @@ #include "net/base/completion_callback.h" #include "net/base/net_log.h" #include "net/http/http_stream.h" +#include "net/spdy/spdy_read_queue.h" #include "net/spdy/spdy_stream.h" namespace net { @@ -89,7 +90,7 @@ class NET_EXPORT_PRIVATE SpdyHttpStream : public SpdyStream::Delegate, base::Time response_time, int status) OVERRIDE; virtual void OnHeadersSent() OVERRIDE; - virtual int OnDataReceived(const char* buffer, int bytes) OVERRIDE; + virtual int OnDataReceived(scoped_ptr<SpdyBuffer> buffer) OVERRIDE; virtual void OnDataSent(size_t bytes_sent) OVERRIDE; virtual void OnClose(int status) OVERRIDE; @@ -139,8 +140,7 @@ class NET_EXPORT_PRIVATE SpdyHttpStream : public SpdyStream::Delegate, bool response_headers_received_; // Indicates waiting for more HEADERS. // We buffer the response body as it arrives asynchronously from the stream. - // TODO(mbelshe): is this infinite buffering? - std::list<scoped_refptr<IOBufferWithSize> > response_body_; + SpdyReadQueue response_body_queue_; CompletionCallback callback_; |