| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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_server_session.h" | 5 #include "net/quic/quic_server_session.h" |
| 6 | 6 |
| 7 #include "base/logging.h" | 7 #include "base/logging.h" |
| 8 #include "net/quic/crypto/source_address_token.h" | 8 #include "net/quic/crypto/source_address_token.h" |
| 9 #include "net/quic/quic_connection.h" | 9 #include "net/quic/quic_connection.h" |
| 10 #include "net/quic/quic_flags.h" | 10 #include "net/quic/quic_flags.h" |
| (...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 45 // kFHDR config maps to FEC protection always for headers stream. | 45 // kFHDR config maps to FEC protection always for headers stream. |
| 46 // TODO(jri): Add crypto stream in addition to headers for kHDR. | 46 // TODO(jri): Add crypto stream in addition to headers for kHDR. |
| 47 headers_stream_->set_fec_policy(FEC_PROTECT_ALWAYS); | 47 headers_stream_->set_fec_policy(FEC_PROTECT_ALWAYS); |
| 48 } | 48 } |
| 49 | 49 |
| 50 void QuicServerSession::OnConnectionClosed(QuicErrorCode error, | 50 void QuicServerSession::OnConnectionClosed(QuicErrorCode error, |
| 51 bool from_peer) { | 51 bool from_peer) { |
| 52 QuicSession::OnConnectionClosed(error, from_peer); | 52 QuicSession::OnConnectionClosed(error, from_peer); |
| 53 // In the unlikely event we get a connection close while doing an asynchronous | 53 // In the unlikely event we get a connection close while doing an asynchronous |
| 54 // crypto event, make sure we cancel the callback. | 54 // crypto event, make sure we cancel the callback. |
| 55 if (crypto_stream_.get() != NULL) { | 55 if (crypto_stream_.get() != nullptr) { |
| 56 crypto_stream_->CancelOutstandingCallbacks(); | 56 crypto_stream_->CancelOutstandingCallbacks(); |
| 57 } | 57 } |
| 58 visitor_->OnConnectionClosed(connection()->connection_id(), error); | 58 visitor_->OnConnectionClosed(connection()->connection_id(), error); |
| 59 } | 59 } |
| 60 | 60 |
| 61 void QuicServerSession::OnWriteBlocked() { | 61 void QuicServerSession::OnWriteBlocked() { |
| 62 QuicSession::OnWriteBlocked(); | 62 QuicSession::OnWriteBlocked(); |
| 63 visitor_->OnWriteBlocked(connection()); | 63 visitor_->OnWriteBlocked(connection()); |
| 64 } | 64 } |
| 65 | 65 |
| (...skipping 84 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 150 << get_max_open_streams() << ")."; | 150 << get_max_open_streams() << ")."; |
| 151 connection()->SendConnectionClose(QUIC_TOO_MANY_OPEN_STREAMS); | 151 connection()->SendConnectionClose(QUIC_TOO_MANY_OPEN_STREAMS); |
| 152 return false; | 152 return false; |
| 153 } | 153 } |
| 154 return true; | 154 return true; |
| 155 } | 155 } |
| 156 | 156 |
| 157 QuicDataStream* QuicServerSession::CreateIncomingDataStream( | 157 QuicDataStream* QuicServerSession::CreateIncomingDataStream( |
| 158 QuicStreamId id) { | 158 QuicStreamId id) { |
| 159 if (!ShouldCreateIncomingDataStream(id)) { | 159 if (!ShouldCreateIncomingDataStream(id)) { |
| 160 return NULL; | 160 return nullptr; |
| 161 } | 161 } |
| 162 | 162 |
| 163 return new QuicSpdyServerStream(id, this); | 163 return new QuicSpdyServerStream(id, this); |
| 164 } | 164 } |
| 165 | 165 |
| 166 QuicDataStream* QuicServerSession::CreateOutgoingDataStream() { | 166 QuicDataStream* QuicServerSession::CreateOutgoingDataStream() { |
| 167 DLOG(ERROR) << "Server push not yet supported"; | 167 DLOG(ERROR) << "Server push not yet supported"; |
| 168 return NULL; | 168 return nullptr; |
| 169 } | 169 } |
| 170 | 170 |
| 171 QuicCryptoServerStream* QuicServerSession::GetCryptoStream() { | 171 QuicCryptoServerStream* QuicServerSession::GetCryptoStream() { |
| 172 return crypto_stream_.get(); | 172 return crypto_stream_.get(); |
| 173 } | 173 } |
| 174 | 174 |
| 175 } // namespace net | 175 } // namespace net |
| OLD | NEW |