OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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_sent_packet_manager.h" | 5 #include "net/quic/core/quic_sent_packet_manager.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 #include <string> | 8 #include <string> |
9 | 9 |
10 #include "base/logging.h" | 10 #include "base/logging.h" |
11 #include "base/stl_util.h" | 11 #include "base/stl_util.h" |
12 #include "net/quic/chromium/quic_utils_chromium.h" | 12 #include "net/quic/chromium/quic_utils_chromium.h" |
13 #include "net/quic/core/congestion_control/general_loss_algorithm.h" | 13 #include "net/quic/core/congestion_control/general_loss_algorithm.h" |
14 #include "net/quic/core/congestion_control/pacing_sender.h" | 14 #include "net/quic/core/congestion_control/pacing_sender.h" |
15 #include "net/quic/core/crypto/crypto_protocol.h" | 15 #include "net/quic/core/crypto/crypto_protocol.h" |
16 #include "net/quic/core/proto/cached_network_parameters.pb.h" | 16 #include "net/quic/core/proto/cached_network_parameters.pb.h" |
17 #include "net/quic/core/quic_bug_tracker.h" | 17 #include "net/quic/core/quic_bug_tracker.h" |
18 #include "net/quic/core/quic_connection_stats.h" | 18 #include "net/quic/core/quic_connection_stats.h" |
19 #include "net/quic/core/quic_flags.h" | 19 #include "net/quic/core/quic_flags.h" |
20 | 20 #include "net/quic/core/quic_pending_retransmission.h" |
21 | 21 |
22 namespace net { | 22 namespace net { |
23 | 23 |
24 namespace { | 24 namespace { |
25 static const int64_t kDefaultRetransmissionTimeMs = 500; | 25 static const int64_t kDefaultRetransmissionTimeMs = 500; |
26 static const int64_t kMaxRetransmissionTimeMs = 60000; | 26 static const int64_t kMaxRetransmissionTimeMs = 60000; |
27 // Maximum number of exponential backoffs used for RTO timeouts. | 27 // Maximum number of exponential backoffs used for RTO timeouts. |
28 static const size_t kMaxRetransmissions = 10; | 28 static const size_t kMaxRetransmissions = 10; |
29 // Maximum number of packets retransmitted upon an RTO. | 29 // Maximum number of packets retransmitted upon an RTO. |
30 static const size_t kMaxRetransmissionsOnTimeout = 2; | 30 static const size_t kMaxRetransmissionsOnTimeout = 2; |
(...skipping 829 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
860 QuicTime::Delta srtt = rtt_stats_.smoothed_rtt(); | 860 QuicTime::Delta srtt = rtt_stats_.smoothed_rtt(); |
861 if (srtt.IsZero()) { | 861 if (srtt.IsZero()) { |
862 srtt = QuicTime::Delta::FromMicroseconds(rtt_stats_.initial_rtt_us()); | 862 srtt = QuicTime::Delta::FromMicroseconds(rtt_stats_.initial_rtt_us()); |
863 } | 863 } |
864 if (enable_half_rtt_tail_loss_probe_ && consecutive_tlp_count_ == 0u) { | 864 if (enable_half_rtt_tail_loss_probe_ && consecutive_tlp_count_ == 0u) { |
865 return QuicTime::Delta::FromMilliseconds( | 865 return QuicTime::Delta::FromMilliseconds( |
866 std::max(kMinTailLossProbeTimeoutMs, | 866 std::max(kMinTailLossProbeTimeoutMs, |
867 static_cast<int64_t>(0.5 * srtt.ToMilliseconds()))); | 867 static_cast<int64_t>(0.5 * srtt.ToMilliseconds()))); |
868 } | 868 } |
869 if (!unacked_packets_.HasMultipleInFlightPackets()) { | 869 if (!unacked_packets_.HasMultipleInFlightPackets()) { |
870 return std::max(2 * srtt, 1.5 * srtt + QuicTime::Delta::FromMilliseconds( | 870 return std::max(2 * srtt, |
871 kMinRetransmissionTimeMs / 2)); | 871 1.5 * srtt + QuicTime::Delta::FromMilliseconds( |
| 872 kMinRetransmissionTimeMs / 2)); |
872 } | 873 } |
873 return QuicTime::Delta::FromMilliseconds( | 874 return QuicTime::Delta::FromMilliseconds( |
874 std::max(kMinTailLossProbeTimeoutMs, | 875 std::max(kMinTailLossProbeTimeoutMs, |
875 static_cast<int64_t>(2 * srtt.ToMilliseconds()))); | 876 static_cast<int64_t>(2 * srtt.ToMilliseconds()))); |
876 } | 877 } |
877 | 878 |
878 const QuicTime::Delta QuicSentPacketManager::GetRetransmissionDelay() const { | 879 const QuicTime::Delta QuicSentPacketManager::GetRetransmissionDelay() const { |
879 QuicTime::Delta retransmission_delay = QuicTime::Delta::Zero(); | 880 QuicTime::Delta retransmission_delay = QuicTime::Delta::Zero(); |
880 if (rtt_stats_.smoothed_rtt().IsZero()) { | 881 if (rtt_stats_.smoothed_rtt().IsZero()) { |
881 // We are in the initial state, use default timeout values. | 882 // We are in the initial state, use default timeout values. |
(...skipping 136 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1018 | 1019 |
1019 void QuicSentPacketManager::OnApplicationLimited() { | 1020 void QuicSentPacketManager::OnApplicationLimited() { |
1020 send_algorithm_->OnApplicationLimited(unacked_packets_.bytes_in_flight()); | 1021 send_algorithm_->OnApplicationLimited(unacked_packets_.bytes_in_flight()); |
1021 } | 1022 } |
1022 | 1023 |
1023 const SendAlgorithmInterface* QuicSentPacketManager::GetSendAlgorithm() const { | 1024 const SendAlgorithmInterface* QuicSentPacketManager::GetSendAlgorithm() const { |
1024 return send_algorithm_.get(); | 1025 return send_algorithm_.get(); |
1025 } | 1026 } |
1026 | 1027 |
1027 } // namespace net | 1028 } // namespace net |
OLD | NEW |