Index: net/quic/chromium/quic_chromium_client_stream.cc |
diff --git a/net/quic/chromium/quic_chromium_client_stream.cc b/net/quic/chromium/quic_chromium_client_stream.cc |
index 5a3d996fb093f1e857d626442b5de31131d8a80a..90e5b05f912f6fe84cb79166124005add49058e7 100644 |
--- a/net/quic/chromium/quic_chromium_client_stream.cc |
+++ b/net/quic/chromium/quic_chromium_client_stream.cc |
@@ -38,33 +38,6 @@ QuicChromiumClientStream::~QuicChromiumClientStream() { |
delegate_->OnClose(); |
} |
-void QuicChromiumClientStream::OnStreamHeadersComplete(bool fin, |
- size_t frame_len) { |
- QuicSpdyStream::OnStreamHeadersComplete(fin, frame_len); |
- if (decompressed_headers().empty() && !decompressed_trailers().empty()) { |
- DCHECK(trailers_decompressed()); |
- // The delegate will read the trailers via a posted task. |
- NotifyDelegateOfHeadersCompleteLater(received_trailers().Clone(), |
- frame_len); |
- } else { |
- DCHECK(!headers_delivered_); |
- SpdyHeaderBlock headers; |
- SpdyFramer framer(HTTP2); |
- size_t headers_len = decompressed_headers().length(); |
- const char* header_data = decompressed_headers().data(); |
- if (!framer.ParseHeaderBlockInBuffer(header_data, headers_len, &headers)) { |
- DLOG(WARNING) << "Invalid headers"; |
- Reset(QUIC_BAD_APPLICATION_PAYLOAD); |
- return; |
- } |
- MarkHeadersConsumed(headers_len); |
- session_->OnInitialHeadersComplete(id(), headers); |
- |
- // The delegate will read the headers via a posted task. |
- NotifyDelegateOfHeadersCompleteLater(std::move(headers), frame_len); |
- } |
-} |
- |
void QuicChromiumClientStream::OnInitialHeadersComplete( |
bool fin, |
size_t frame_len, |
@@ -95,23 +68,6 @@ void QuicChromiumClientStream::OnTrailingHeadersComplete( |
NotifyDelegateOfHeadersCompleteLater(received_trailers().Clone(), frame_len); |
} |
-void QuicChromiumClientStream::OnPromiseHeadersComplete( |
- QuicStreamId promised_id, |
- size_t frame_len) { |
- size_t headers_len = decompressed_headers().length(); |
- SpdyHeaderBlock headers; |
- SpdyFramer framer(HTTP2); |
- if (!framer.ParseHeaderBlockInBuffer(decompressed_headers().data(), |
- headers_len, &headers)) { |
- DLOG(WARNING) << "Invalid headers"; |
- Reset(QUIC_BAD_APPLICATION_PAYLOAD); |
- return; |
- } |
- MarkHeadersConsumed(headers_len); |
- |
- session_->HandlePromised(id(), promised_id, headers); |
-} |
- |
void QuicChromiumClientStream::OnPromiseHeaderList( |
QuicStreamId promised_id, |
size_t frame_len, |
@@ -291,7 +247,6 @@ void QuicChromiumClientStream::NotifyDelegateOfHeadersComplete( |
return; |
// Only mark trailers consumed when we are about to notify delegate. |
if (headers_delivered_) { |
- MarkTrailersConsumed(decompressed_trailers().length()); |
MarkTrailersConsumed(); |
// Post an async task to notify delegate of the FIN flag. |
NotifyDelegateOfDataAvailableLater(); |