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 1349 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1360 if (peer_ip_changed_ || peer_port_changed_) { | 1360 if (peer_ip_changed_ || peer_port_changed_) { |
1361 IPEndPoint old_peer_address = peer_address_; | 1361 IPEndPoint old_peer_address = peer_address_; |
1362 peer_address_ = IPEndPoint( | 1362 peer_address_ = IPEndPoint( |
1363 peer_ip_changed_ ? migrating_peer_ip_ : peer_address_.address(), | 1363 peer_ip_changed_ ? migrating_peer_ip_ : peer_address_.address(), |
1364 peer_port_changed_ ? migrating_peer_port_ : peer_address_.port()); | 1364 peer_port_changed_ ? migrating_peer_port_ : peer_address_.port()); |
1365 | 1365 |
1366 DVLOG(1) << ENDPOINT << "Peer's ip:port changed from " | 1366 DVLOG(1) << ENDPOINT << "Peer's ip:port changed from " |
1367 << old_peer_address.ToString() << " to " | 1367 << old_peer_address.ToString() << " to " |
1368 << peer_address_.ToString() << ", migrating connection."; | 1368 << peer_address_.ToString() << ", migrating connection."; |
1369 | 1369 |
1370 if (FLAGS_send_goaway_after_client_migration) { | 1370 visitor_->OnConnectionMigration(); |
1371 visitor_->OnConnectionMigration(); | |
1372 } | |
1373 } | 1371 } |
1374 | 1372 |
1375 time_of_last_received_packet_ = clock_->Now(); | 1373 time_of_last_received_packet_ = clock_->Now(); |
1376 DVLOG(1) << ENDPOINT << "time of last received packet: " | 1374 DVLOG(1) << ENDPOINT << "time of last received packet: " |
1377 << time_of_last_received_packet_.ToDebuggingValue(); | 1375 << time_of_last_received_packet_.ToDebuggingValue(); |
1378 | 1376 |
1379 if (last_size_ > largest_received_packet_size_) { | 1377 if (last_size_ > largest_received_packet_size_) { |
1380 largest_received_packet_size_ = last_size_; | 1378 largest_received_packet_size_ = last_size_; |
1381 } | 1379 } |
1382 | 1380 |
(...skipping 943 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2326 packet_number_of_last_sent_packet_ + packets_between_mtu_probes_ + 1; | 2324 packet_number_of_last_sent_packet_ + packets_between_mtu_probes_ + 1; |
2327 ++mtu_probe_count_; | 2325 ++mtu_probe_count_; |
2328 | 2326 |
2329 DVLOG(2) << "Sending a path MTU discovery packet #" << mtu_probe_count_; | 2327 DVLOG(2) << "Sending a path MTU discovery packet #" << mtu_probe_count_; |
2330 SendMtuDiscoveryPacket(mtu_discovery_target_); | 2328 SendMtuDiscoveryPacket(mtu_discovery_target_); |
2331 | 2329 |
2332 DCHECK(!mtu_discovery_alarm_->IsSet()); | 2330 DCHECK(!mtu_discovery_alarm_->IsSet()); |
2333 } | 2331 } |
2334 | 2332 |
2335 } // namespace net | 2333 } // namespace net |
OLD | NEW |