| Index: trunk/src/net/quic/quic_session.cc
|
| ===================================================================
|
| --- trunk/src/net/quic/quic_session.cc (revision 198763)
|
| +++ trunk/src/net/quic/quic_session.cc (working copy)
|
| @@ -108,20 +108,6 @@
|
| stream->OnStreamFrame(frames[i]);
|
| }
|
| }
|
| -
|
| - while (!decompression_blocked_streams_.empty()) {
|
| - QuicHeaderId header_id = decompression_blocked_streams_.begin()->first;
|
| - if (header_id == decompressor_.current_header_id()) {
|
| - QuicStreamId stream_id = decompression_blocked_streams_.begin()->second;
|
| - decompression_blocked_streams_.erase(header_id);
|
| - ReliableQuicStream* stream = GetStream(stream_id);
|
| - if (!stream) {
|
| - connection()->SendConnectionClose(
|
| - QUIC_STREAM_RST_BEFORE_HEADERS_DECOMPRESSED);
|
| - }
|
| - stream->OnDecompressorAvailable();
|
| - }
|
| - }
|
| return true;
|
| }
|
|
|
| @@ -316,11 +302,6 @@
|
| write_blocked_streams_.AddBlockedObject(id);
|
| }
|
|
|
| -void QuicSession::MarkDecompressionBlocked(QuicHeaderId header_id,
|
| - QuicStreamId stream_id) {
|
| - decompression_blocked_streams_[header_id] = stream_id;
|
| -}
|
| -
|
| void QuicSession::PostProcessAfterData() {
|
| STLDeleteElements(&closed_streams_);
|
| closed_streams_.clear();
|
|
|