OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "net/quic/quic_chromium_client_stream.h" | 5 #include "net/quic/quic_chromium_client_stream.h" |
6 | 6 |
7 #include "base/callback_helpers.h" | 7 #include "base/callback_helpers.h" |
8 #include "base/location.h" | 8 #include "base/location.h" |
9 #include "base/threading/thread_task_runner_handle.h" | 9 #include "base/threading/thread_task_runner_handle.h" |
10 #include "net/base/io_buffer.h" | 10 #include "net/base/io_buffer.h" |
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
53 return; | 53 return; |
54 } | 54 } |
55 MarkHeadersConsumed(headers_len); | 55 MarkHeadersConsumed(headers_len); |
56 session_->OnInitialHeadersComplete(id(), headers); | 56 session_->OnInitialHeadersComplete(id(), headers); |
57 | 57 |
58 // The delegate will read the headers via a posted task. | 58 // The delegate will read the headers via a posted task. |
59 NotifyDelegateOfHeadersCompleteLater(headers, frame_len); | 59 NotifyDelegateOfHeadersCompleteLater(headers, frame_len); |
60 } | 60 } |
61 } | 61 } |
62 | 62 |
63 void QuicChromiumClientStream::OnInitialHeadersComplete( | |
64 bool fin, | |
65 size_t frame_len, | |
66 const QuicHeaderList& header_list) { | |
67 QuicSpdyStream::OnInitialHeadersComplete(fin, frame_len, header_list); | |
68 | |
69 SpdyHeaderBlock header_block; | |
70 int64_t length = -1; | |
71 if (!SpdyUtils::CopyAndValidateHeaders(header_list, &length, &header_block)) { | |
72 DLOG(ERROR) << "Failed to parse header list: " << header_list.DebugString(); | |
73 ConsumeHeaderList(); | |
74 Reset(QUIC_BAD_APPLICATION_PAYLOAD); | |
75 return; | |
76 } | |
77 | |
78 ConsumeHeaderList(); | |
79 session_->OnInitialHeadersComplete(id(), header_block); | |
80 | |
81 // The delegate will read the headers via a posted task. | |
82 NotifyDelegateOfHeadersCompleteLater(header_block, frame_len); | |
83 } | |
84 | |
85 void QuicChromiumClientStream::OnTrailingHeadersComplete( | |
86 bool fin, | |
87 size_t frame_len, | |
88 const QuicHeaderList& header_list) { | |
89 QuicSpdyStream::OnTrailingHeadersComplete(fin, frame_len, header_list); | |
90 NotifyDelegateOfHeadersCompleteLater(received_trailers(), frame_len); | |
91 } | |
92 | |
93 void QuicChromiumClientStream::OnPromiseHeadersComplete( | 63 void QuicChromiumClientStream::OnPromiseHeadersComplete( |
94 QuicStreamId promised_id, | 64 QuicStreamId promised_id, |
95 size_t frame_len) { | 65 size_t frame_len) { |
96 size_t headers_len = decompressed_headers().length(); | 66 size_t headers_len = decompressed_headers().length(); |
97 SpdyHeaderBlock headers; | 67 SpdyHeaderBlock headers; |
98 SpdyFramer framer(HTTP2); | 68 SpdyFramer framer(HTTP2); |
99 if (!framer.ParseHeaderBlockInBuffer(decompressed_headers().data(), | 69 if (!framer.ParseHeaderBlockInBuffer(decompressed_headers().data(), |
100 headers_len, &headers)) { | 70 headers_len, &headers)) { |
101 DLOG(WARNING) << "Invalid headers"; | 71 DLOG(WARNING) << "Invalid headers"; |
102 Reset(QUIC_BAD_APPLICATION_PAYLOAD); | 72 Reset(QUIC_BAD_APPLICATION_PAYLOAD); |
(...skipping 142 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
245 } | 215 } |
246 | 216 |
247 void QuicChromiumClientStream::NotifyDelegateOfHeadersComplete( | 217 void QuicChromiumClientStream::NotifyDelegateOfHeadersComplete( |
248 SpdyHeaderBlock headers, | 218 SpdyHeaderBlock headers, |
249 size_t frame_len) { | 219 size_t frame_len) { |
250 if (!delegate_) | 220 if (!delegate_) |
251 return; | 221 return; |
252 // Only mark trailers consumed when we are about to notify delegate. | 222 // Only mark trailers consumed when we are about to notify delegate. |
253 if (headers_delivered_) { | 223 if (headers_delivered_) { |
254 MarkTrailersConsumed(decompressed_trailers().length()); | 224 MarkTrailersConsumed(decompressed_trailers().length()); |
255 MarkTrailersDelivered(); | |
256 net_log_.AddEvent( | 225 net_log_.AddEvent( |
257 NetLog::TYPE_QUIC_CHROMIUM_CLIENT_STREAM_READ_RESPONSE_TRAILERS, | 226 NetLog::TYPE_QUIC_CHROMIUM_CLIENT_STREAM_READ_RESPONSE_TRAILERS, |
258 base::Bind(&SpdyHeaderBlockNetLogCallback, &headers)); | 227 base::Bind(&SpdyHeaderBlockNetLogCallback, &headers)); |
259 } else { | 228 } else { |
260 headers_delivered_ = true; | 229 headers_delivered_ = true; |
261 net_log_.AddEvent( | 230 net_log_.AddEvent( |
262 NetLog::TYPE_QUIC_CHROMIUM_CLIENT_STREAM_READ_RESPONSE_HEADERS, | 231 NetLog::TYPE_QUIC_CHROMIUM_CLIENT_STREAM_READ_RESPONSE_HEADERS, |
263 base::Bind(&SpdyHeaderBlockNetLogCallback, &headers)); | 232 base::Bind(&SpdyHeaderBlockNetLogCallback, &headers)); |
264 } | 233 } |
265 | 234 |
(...skipping 17 matching lines...) Expand all Loading... |
283 } else { | 252 } else { |
284 delegate_tasks_.push_back(closure); | 253 delegate_tasks_.push_back(closure); |
285 } | 254 } |
286 } | 255 } |
287 | 256 |
288 void QuicChromiumClientStream::DisableConnectionMigration() { | 257 void QuicChromiumClientStream::DisableConnectionMigration() { |
289 can_migrate_ = false; | 258 can_migrate_ = false; |
290 } | 259 } |
291 | 260 |
292 } // namespace net | 261 } // namespace net |
OLD | NEW |