| 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 |