Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(61)

Side by Side Diff: net/quic/core/quic_sent_packet_manager.cc

Issue 2603723002: Add a new QUIC platform API for text utilities. (Closed)
Patch Set: net/tools/quic/quic_packet_printer_bin.cc Created 3 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « net/quic/core/quic_packets.cc ('k') | net/quic/core/quic_session.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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
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
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
OLDNEW
« no previous file with comments | « net/quic/core/quic_packets.cc ('k') | net/quic/core/quic_session.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698