| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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_connection.h" | 5 #include "net/quic/quic_connection.h" |
| 6 | 6 |
| 7 #include <string.h> | 7 #include <string.h> |
| 8 #include <sys/types.h> | 8 #include <sys/types.h> |
| 9 | 9 |
| 10 #include <algorithm> | 10 #include <algorithm> |
| (...skipping 294 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 305 | 305 |
| 306 sent_packet_manager_.SetFromConfig(config); | 306 sent_packet_manager_.SetFromConfig(config); |
| 307 if (config.HasReceivedBytesForConnectionId() && | 307 if (config.HasReceivedBytesForConnectionId() && |
| 308 can_truncate_connection_ids_) { | 308 can_truncate_connection_ids_) { |
| 309 packet_generator_.SetConnectionIdLength( | 309 packet_generator_.SetConnectionIdLength( |
| 310 config.ReceivedBytesForConnectionId()); | 310 config.ReceivedBytesForConnectionId()); |
| 311 } | 311 } |
| 312 max_undecryptable_packets_ = config.max_undecryptable_packets(); | 312 max_undecryptable_packets_ = config.max_undecryptable_packets(); |
| 313 } | 313 } |
| 314 | 314 |
| 315 void QuicConnection::OnSendConnectionState( |
| 316 const CachedNetworkParameters& cached_network_params) { |
| 317 if (debug_visitor_ != nullptr) { |
| 318 debug_visitor_->OnSendConnectionState(cached_network_params); |
| 319 } |
| 320 } |
| 321 |
| 315 bool QuicConnection::ResumeConnectionState( | 322 bool QuicConnection::ResumeConnectionState( |
| 316 const CachedNetworkParameters& cached_network_params) { | 323 const CachedNetworkParameters& cached_network_params) { |
| 324 if (debug_visitor_ != nullptr) { |
| 325 debug_visitor_->OnResumeConnectionState(cached_network_params); |
| 326 } |
| 317 return sent_packet_manager_.ResumeConnectionState(cached_network_params); | 327 return sent_packet_manager_.ResumeConnectionState(cached_network_params); |
| 318 } | 328 } |
| 319 | 329 |
| 320 void QuicConnection::SetNumOpenStreams(size_t num_streams) { | 330 void QuicConnection::SetNumOpenStreams(size_t num_streams) { |
| 321 sent_packet_manager_.SetNumOpenStreams(num_streams); | 331 sent_packet_manager_.SetNumOpenStreams(num_streams); |
| 322 } | 332 } |
| 323 | 333 |
| 324 bool QuicConnection::SelectMutualVersion( | 334 bool QuicConnection::SelectMutualVersion( |
| 325 const QuicVersionVector& available_versions) { | 335 const QuicVersionVector& available_versions) { |
| 326 // Try to find the highest mutual version by iterating over supported | 336 // Try to find the highest mutual version by iterating over supported |
| (...skipping 1755 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2082 } | 2092 } |
| 2083 for (const QuicFrame& frame : retransmittable_frames->frames()) { | 2093 for (const QuicFrame& frame : retransmittable_frames->frames()) { |
| 2084 if (frame.type == CONNECTION_CLOSE_FRAME) { | 2094 if (frame.type == CONNECTION_CLOSE_FRAME) { |
| 2085 return true; | 2095 return true; |
| 2086 } | 2096 } |
| 2087 } | 2097 } |
| 2088 return false; | 2098 return false; |
| 2089 } | 2099 } |
| 2090 | 2100 |
| 2091 } // namespace net | 2101 } // namespace net |
| OLD | NEW |