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 |