OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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_headers_stream.h" | 5 #include "net/quic/quic_headers_stream.h" |
6 | 6 |
7 #include "base/metrics/histogram_macros.h" | 7 #include "base/metrics/histogram_macros.h" |
8 #include "base/strings/stringprintf.h" | 8 #include "base/strings/stringprintf.h" |
9 #include "net/quic/quic_flags.h" | 9 #include "net/quic/quic_flags.h" |
10 #include "net/quic/quic_headers_stream.h" | 10 #include "net/quic/quic_headers_stream.h" |
(...skipping 235 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
246 } | 246 } |
247 if (spdy_framer_.ProcessInput(static_cast<char*>(iov.iov_base), | 247 if (spdy_framer_.ProcessInput(static_cast<char*>(iov.iov_base), |
248 iov.iov_len) != iov.iov_len) { | 248 iov.iov_len) != iov.iov_len) { |
249 // Error processing data. | 249 // Error processing data. |
250 return; | 250 return; |
251 } | 251 } |
252 sequencer()->MarkConsumed(iov.iov_len); | 252 sequencer()->MarkConsumed(iov.iov_len); |
253 } | 253 } |
254 } | 254 } |
255 | 255 |
256 QuicPriority QuicHeadersStream::EffectivePriority() const { return 0; } | 256 QuicPriority QuicHeadersStream::Priority() const { |
| 257 return QuicWriteBlockedList::kHighestPriority; |
| 258 } |
257 | 259 |
258 void QuicHeadersStream::OnSynStream(SpdyStreamId stream_id, | 260 void QuicHeadersStream::OnSynStream(SpdyStreamId stream_id, |
259 SpdyPriority priority, | 261 SpdyPriority priority, |
260 bool fin) { | 262 bool fin) { |
261 if (session()->perspective() == Perspective::IS_CLIENT) { | 263 if (session()->perspective() == Perspective::IS_CLIENT) { |
262 CloseConnectionWithDetails( | 264 CloseConnectionWithDetails( |
263 QUIC_INVALID_HEADERS_STREAM_DATA, | 265 QUIC_INVALID_HEADERS_STREAM_DATA, |
264 "SPDY SYN_STREAM frame received at the client"); | 266 "SPDY SYN_STREAM frame received at the client"); |
265 return; | 267 return; |
266 } | 268 } |
(...skipping 49 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
316 | 318 |
317 void QuicHeadersStream::OnCompressedFrameSize(size_t frame_len) { | 319 void QuicHeadersStream::OnCompressedFrameSize(size_t frame_len) { |
318 frame_len_ += frame_len; | 320 frame_len_ += frame_len; |
319 } | 321 } |
320 | 322 |
321 bool QuicHeadersStream::IsConnected() { | 323 bool QuicHeadersStream::IsConnected() { |
322 return session()->connection()->connected(); | 324 return session()->connection()->connected(); |
323 } | 325 } |
324 | 326 |
325 } // namespace net | 327 } // namespace net |
OLD | NEW |