Index: net/quic/quic_chromium_client_stream.cc |
diff --git a/net/quic/quic_chromium_client_stream.cc b/net/quic/quic_chromium_client_stream.cc |
index 0f21d51127ae865b6908af42c7f84e9c14d14e42..2b72c95174b7d595a344f1a07231cf12f757fb22 100644 |
--- a/net/quic/quic_chromium_client_stream.cc |
+++ b/net/quic/quic_chromium_client_stream.cc |
@@ -60,6 +60,36 @@ void QuicChromiumClientStream::OnStreamHeadersComplete(bool fin, |
} |
} |
+void QuicChromiumClientStream::OnInitialHeadersComplete( |
+ bool fin, |
+ size_t frame_len, |
+ const QuicHeaderList& header_list) { |
+ QuicSpdyStream::OnInitialHeadersComplete(fin, frame_len, header_list); |
+ |
+ SpdyHeaderBlock header_block; |
+ int64_t length = -1; |
+ if (!SpdyUtils::CopyAndValidateHeaders(header_list, &length, &header_block)) { |
+ DLOG(ERROR) << "Failed to parse header list: " << header_list.DebugString(); |
+ ConsumeHeaderList(); |
+ Reset(QUIC_BAD_APPLICATION_PAYLOAD); |
+ return; |
+ } |
+ |
+ ConsumeHeaderList(); |
+ session_->OnInitialHeadersComplete(id(), header_block); |
+ |
+ // The delegate will read the headers via a posted task. |
+ NotifyDelegateOfHeadersCompleteLater(header_block, frame_len); |
+} |
+ |
+void QuicChromiumClientStream::OnTrailingHeadersComplete( |
+ bool fin, |
+ size_t frame_len, |
+ const QuicHeaderList& header_list) { |
+ QuicSpdyStream::OnTrailingHeadersComplete(fin, frame_len, header_list); |
+ NotifyDelegateOfHeadersCompleteLater(received_trailers(), frame_len); |
+} |
+ |
void QuicChromiumClientStream::OnPromiseHeadersComplete( |
QuicStreamId promised_id, |
size_t frame_len) { |
@@ -222,6 +252,7 @@ void QuicChromiumClientStream::NotifyDelegateOfHeadersComplete( |
// Only mark trailers consumed when we are about to notify delegate. |
if (headers_delivered_) { |
MarkTrailersConsumed(decompressed_trailers().length()); |
+ MarkTrailersDelivered(); |
net_log_.AddEvent( |
NetLog::TYPE_QUIC_CHROMIUM_CLIENT_STREAM_READ_RESPONSE_TRAILERS, |
base::Bind(&SpdyHeaderBlockNetLogCallback, &headers)); |