| 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 |