OLD | NEW |
1 // Copyright (c) 2015 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2015 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/core/quic_spdy_session.h" | 5 #include "net/quic/core/quic_spdy_session.h" |
6 | 6 |
7 #include <utility> | 7 #include <utility> |
8 | 8 |
9 #include "net/quic/core/quic_bug_tracker.h" | 9 #include "net/quic/core/quic_bug_tracker.h" |
10 #include "net/quic/core/quic_headers_stream.h" | 10 #include "net/quic/core/quic_headers_stream.h" |
(...skipping 84 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
95 void QuicSpdySession::UpdateStreamPriority(QuicStreamId id, | 95 void QuicSpdySession::UpdateStreamPriority(QuicStreamId id, |
96 SpdyPriority new_priority) { | 96 SpdyPriority new_priority) { |
97 write_blocked_streams()->UpdateStreamPriority(id, new_priority); | 97 write_blocked_streams()->UpdateStreamPriority(id, new_priority); |
98 } | 98 } |
99 | 99 |
100 QuicSpdyStream* QuicSpdySession::GetSpdyDataStream( | 100 QuicSpdyStream* QuicSpdySession::GetSpdyDataStream( |
101 const QuicStreamId stream_id) { | 101 const QuicStreamId stream_id) { |
102 return static_cast<QuicSpdyStream*>(GetOrCreateDynamicStream(stream_id)); | 102 return static_cast<QuicSpdyStream*>(GetOrCreateDynamicStream(stream_id)); |
103 } | 103 } |
104 | 104 |
| 105 void QuicSpdySession::OnCryptoHandshakeEvent(CryptoHandshakeEvent event) { |
| 106 QuicSession::OnCryptoHandshakeEvent(event); |
| 107 if (FLAGS_quic_send_max_header_list_size && event == HANDSHAKE_CONFIRMED && |
| 108 config()->SupportMaxHeaderListSize()) { |
| 109 headers_stream()->SendMaxHeaderListSize(kDefaultMaxUncompressedHeaderSize); |
| 110 } |
| 111 } |
| 112 |
105 void QuicSpdySession::OnPromiseHeaderList(QuicStreamId stream_id, | 113 void QuicSpdySession::OnPromiseHeaderList(QuicStreamId stream_id, |
106 QuicStreamId promised_stream_id, | 114 QuicStreamId promised_stream_id, |
107 size_t frame_len, | 115 size_t frame_len, |
108 const QuicHeaderList& header_list) { | 116 const QuicHeaderList& header_list) { |
109 string error = "OnPromiseHeaderList should be overriden in client code."; | 117 string error = "OnPromiseHeaderList should be overriden in client code."; |
110 QUIC_BUG << error; | 118 QUIC_BUG << error; |
111 connection()->CloseConnection(QUIC_INTERNAL_ERROR, error, | 119 connection()->CloseConnection(QUIC_INTERNAL_ERROR, error, |
112 ConnectionCloseBehavior::SILENT_CLOSE); | 120 ConnectionCloseBehavior::SILENT_CLOSE); |
113 } | 121 } |
114 | 122 |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
148 DVLOG(1) << "De-encapsulating DATA frame for stream " << stream_id | 156 DVLOG(1) << "De-encapsulating DATA frame for stream " << stream_id |
149 << " offset " << offset << " len " << len << " fin " << fin; | 157 << " offset " << offset << " len " << len << " fin " << fin; |
150 OnStreamFrame(frame); | 158 OnStreamFrame(frame); |
151 } | 159 } |
152 | 160 |
153 bool QuicSpdySession::ShouldReleaseHeadersStreamSequencerBuffer() { | 161 bool QuicSpdySession::ShouldReleaseHeadersStreamSequencerBuffer() { |
154 return false; | 162 return false; |
155 } | 163 } |
156 | 164 |
157 } // namespace net | 165 } // namespace net |
OLD | NEW |