| 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 190 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 201 // The headers stream is exempt from connection level flow control. | 201 // The headers stream is exempt from connection level flow control. |
| 202 DisableConnectionFlowControlForThisStream(); | 202 DisableConnectionFlowControlForThisStream(); |
| 203 } | 203 } |
| 204 | 204 |
| 205 QuicHeadersStream::~QuicHeadersStream() {} | 205 QuicHeadersStream::~QuicHeadersStream() {} |
| 206 | 206 |
| 207 size_t QuicHeadersStream::WriteHeaders( | 207 size_t QuicHeadersStream::WriteHeaders( |
| 208 QuicStreamId stream_id, | 208 QuicStreamId stream_id, |
| 209 const SpdyHeaderBlock& headers, | 209 const SpdyHeaderBlock& headers, |
| 210 bool fin, | 210 bool fin, |
| 211 QuicPriority priority, | 211 SpdyPriority priority, |
| 212 QuicAckListenerInterface* ack_notifier_delegate) { | 212 QuicAckListenerInterface* ack_notifier_delegate) { |
| 213 SpdyHeadersIR headers_frame(stream_id); | 213 SpdyHeadersIR headers_frame(stream_id); |
| 214 headers_frame.set_header_block(headers); | 214 headers_frame.set_header_block(headers); |
| 215 headers_frame.set_fin(fin); | 215 headers_frame.set_fin(fin); |
| 216 if (session()->perspective() == Perspective::IS_CLIENT) { | 216 if (session()->perspective() == Perspective::IS_CLIENT) { |
| 217 headers_frame.set_has_priority(true); | 217 headers_frame.set_has_priority(true); |
| 218 headers_frame.set_priority(priority); | 218 headers_frame.set_priority(priority); |
| 219 } | 219 } |
| 220 scoped_ptr<SpdySerializedFrame> frame( | 220 scoped_ptr<SpdySerializedFrame> frame( |
| 221 spdy_framer_.SerializeFrame(headers_frame)); | 221 spdy_framer_.SerializeFrame(headers_frame)); |
| (...skipping 24 matching lines...) Expand all 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::Priority() const { | 256 SpdyPriority QuicHeadersStream::Priority() const { |
| 257 return QuicWriteBlockedList::kHighestPriority; | 257 return net::kHighestPriority; // The smallest priority is also the highest |
| 258 } | 258 } |
| 259 | 259 |
| 260 void QuicHeadersStream::OnSynStream(SpdyStreamId stream_id, | 260 void QuicHeadersStream::OnSynStream(SpdyStreamId stream_id, |
| 261 SpdyPriority priority, | 261 SpdyPriority priority, |
| 262 bool fin) { | 262 bool fin) { |
| 263 if (session()->perspective() == Perspective::IS_CLIENT) { | 263 if (session()->perspective() == Perspective::IS_CLIENT) { |
| 264 CloseConnectionWithDetails( | 264 CloseConnectionWithDetails( |
| 265 QUIC_INVALID_HEADERS_STREAM_DATA, | 265 QUIC_INVALID_HEADERS_STREAM_DATA, |
| 266 "SPDY SYN_STREAM frame received at the client"); | 266 "SPDY SYN_STREAM frame received at the client"); |
| 267 return; | 267 return; |
| (...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 318 | 318 |
| 319 void QuicHeadersStream::OnCompressedFrameSize(size_t frame_len) { | 319 void QuicHeadersStream::OnCompressedFrameSize(size_t frame_len) { |
| 320 frame_len_ += frame_len; | 320 frame_len_ += frame_len; |
| 321 } | 321 } |
| 322 | 322 |
| 323 bool QuicHeadersStream::IsConnected() { | 323 bool QuicHeadersStream::IsConnected() { |
| 324 return session()->connection()->connected(); | 324 return session()->connection()->connected(); |
| 325 } | 325 } |
| 326 | 326 |
| 327 } // namespace net | 327 } // namespace net |
| OLD | NEW |