| Index: net/quic/quic_data_stream.h
|
| diff --git a/net/quic/quic_data_stream.h b/net/quic/quic_data_stream.h
|
| index 8cb1c2c7f74668563785d21eabbbb4d58b2850d6..adbc707bd9c90b61d788eb59c59c68e847cd4290 100644
|
| --- a/net/quic/quic_data_stream.h
|
| +++ b/net/quic/quic_data_stream.h
|
| @@ -19,10 +19,9 @@
|
| #include "net/base/net_export.h"
|
| #include "net/quic/quic_ack_notifier.h"
|
| #include "net/quic/quic_protocol.h"
|
| -#include "net/quic/quic_spdy_compressor.h"
|
| -#include "net/quic/quic_spdy_decompressor.h"
|
| #include "net/quic/quic_stream_sequencer.h"
|
| #include "net/quic/reliable_quic_stream.h"
|
| +#include "net/spdy/spdy_framer.h"
|
|
|
| namespace net {
|
|
|
| @@ -36,8 +35,7 @@ class QuicSession;
|
| class SSLInfo;
|
|
|
| // All this does right now is send data to subclasses via the sequencer.
|
| -class NET_EXPORT_PRIVATE QuicDataStream : public ReliableQuicStream,
|
| - public QuicSpdyDecompressor::Visitor {
|
| +class NET_EXPORT_PRIVATE QuicDataStream : public ReliableQuicStream {
|
| public:
|
| // Visitor receives callbacks from the stream.
|
| class Visitor {
|
| @@ -67,18 +65,12 @@ class NET_EXPORT_PRIVATE QuicDataStream : public ReliableQuicStream,
|
| // priority.
|
| virtual QuicPriority EffectivePriority() const OVERRIDE;
|
|
|
| - // QuicSpdyDecompressor::Visitor implementation.
|
| - virtual bool OnDecompressedData(base::StringPiece data) OVERRIDE;
|
| - virtual void OnDecompressionError() OVERRIDE;
|
| -
|
| - // Overridden by subclasses to process data. For QUIC_VERSION_12 or less,
|
| - // data will be delivered in order, first the decompressed headers, then
|
| - // the body. For later QUIC versions, the headers will be delivered via
|
| - // OnStreamHeaders, and only the data will be delivered through this method.
|
| + // Overridden by subclasses to process data. The headers will be delivered
|
| + // via OnStreamHeaders, so only data will be delivered through this method.
|
| virtual uint32 ProcessData(const char* data, uint32 data_len) = 0;
|
|
|
| // Called by the session when decompressed headers data is received
|
| - // for this stream. Only called for versions greater than QUIC_VERSION_12.
|
| + // for this stream.
|
| // May be called multiple times, with each call providing additional headers
|
| // data until OnStreamHeadersComplete is called.
|
| virtual void OnStreamHeaders(base::StringPiece headers_data);
|
| @@ -90,7 +82,6 @@ class NET_EXPORT_PRIVATE QuicDataStream : public ReliableQuicStream,
|
| // Called by the session when decompressed headers have been completely
|
| // delilvered to this stream. If |fin| is true, then this stream
|
| // should be closed; no more data will be sent by the peer.
|
| - // Only called for versions greater than QUIC_VERSION_12.
|
| virtual void OnStreamHeadersComplete(bool fin, size_t frame_len);
|
|
|
| // Writes the headers contained in |header_block| to the dedicated
|
| @@ -107,18 +98,12 @@ class NET_EXPORT_PRIVATE QuicDataStream : public ReliableQuicStream,
|
| virtual bool IsDoneReading() const;
|
| virtual bool HasBytesToRead() const;
|
|
|
| - // Called by the session when a decompression blocked stream
|
| - // becomes unblocked.
|
| - virtual void OnDecompressorAvailable();
|
| -
|
| void set_visitor(Visitor* visitor) { visitor_ = visitor; }
|
|
|
| bool headers_decompressed() const { return headers_decompressed_; }
|
|
|
| const IPEndPoint& GetPeerAddress();
|
|
|
| - QuicSpdyCompressor* compressor();
|
| -
|
| // Gets the SSL connection information.
|
| bool GetSSLInfo(SSLInfo* ssl_info);
|
|
|
| @@ -138,13 +123,8 @@ class NET_EXPORT_PRIVATE QuicDataStream : public ReliableQuicStream,
|
| friend class test::ReliableQuicStreamPeer;
|
| friend class QuicStreamUtils;
|
|
|
| - // Processes raw stream data for QUIC_VERSION_12 and earlier.
|
| - uint32 ProcessRawData12(const char* data, uint32 data_len);
|
| -
|
| uint32 ProcessHeaderData();
|
|
|
| - uint32 StripPriorityAndHeaderId(const char* data, uint32 data_len);
|
| -
|
| bool FinishedReadingHeaders();
|
|
|
| Visitor* visitor_;
|
| @@ -152,11 +132,6 @@ class NET_EXPORT_PRIVATE QuicDataStream : public ReliableQuicStream,
|
| bool headers_decompressed_;
|
| // The priority of the stream, once parsed.
|
| QuicPriority priority_;
|
| - // ID of the header block sent by the peer, once parsed.
|
| - QuicHeaderId headers_id_;
|
| - // Buffer into which we write bytes from priority_ and headers_id_
|
| - // until each is fully parsed.
|
| - string headers_id_and_priority_buffer_;
|
| // Contains a copy of the decompressed headers until they are consumed
|
| // via ProcessData or Readv.
|
| string decompressed_headers_;
|
|
|