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