| OLD | NEW |
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 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/congestion_control/bbr_sender.h" | 5 #include "net/quic/core/congestion_control/bbr_sender.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 #include <sstream> | 8 #include <sstream> |
| 9 | 9 |
| 10 #include "net/quic/core/congestion_control/rtt_stats.h" | 10 #include "net/quic/core/congestion_control/rtt_stats.h" |
| 11 #include "net/quic/core/crypto/crypto_protocol.h" | 11 #include "net/quic/core/crypto/crypto_protocol.h" |
| 12 #include "net/quic/core/proto/cached_network_parameters.pb.h" | 12 #include "net/quic/core/proto/cached_network_parameters.pb.h" |
| 13 #include "net/quic/core/quic_flags.h" | |
| 14 #include "net/quic/platform/api/quic_bug_tracker.h" | 13 #include "net/quic/platform/api/quic_bug_tracker.h" |
| 15 #include "net/quic/platform/api/quic_flag_utils.h" | 14 #include "net/quic/platform/api/quic_flag_utils.h" |
| 15 #include "net/quic/platform/api/quic_flags.h" |
| 16 #include "net/quic/platform/api/quic_logging.h" | 16 #include "net/quic/platform/api/quic_logging.h" |
| 17 | 17 |
| 18 namespace net { | 18 namespace net { |
| 19 | 19 |
| 20 namespace { | 20 namespace { |
| 21 // Constants based on TCP defaults. | 21 // Constants based on TCP defaults. |
| 22 const QuicByteCount kMaxSegmentSize = kDefaultTCPMSS; | 22 const QuicByteCount kMaxSegmentSize = kDefaultTCPMSS; |
| 23 // The minimum CWND to ensure delayed acks don't reduce bandwidth measurements. | 23 // The minimum CWND to ensure delayed acks don't reduce bandwidth measurements. |
| 24 // Does not inflate the pacing rate. | 24 // Does not inflate the pacing rate. |
| 25 const QuicByteCount kMinimumCongestionWindow = 4 * kMaxSegmentSize; | 25 const QuicByteCount kMinimumCongestionWindow = 4 * kMaxSegmentSize; |
| (...skipping 60 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 86 min_rtt_(QuicTime::Delta::Zero()), | 86 min_rtt_(QuicTime::Delta::Zero()), |
| 87 min_rtt_timestamp_(QuicTime::Zero()), | 87 min_rtt_timestamp_(QuicTime::Zero()), |
| 88 congestion_window_(initial_tcp_congestion_window * kDefaultTCPMSS), | 88 congestion_window_(initial_tcp_congestion_window * kDefaultTCPMSS), |
| 89 initial_congestion_window_(initial_tcp_congestion_window * | 89 initial_congestion_window_(initial_tcp_congestion_window * |
| 90 kDefaultTCPMSS), | 90 kDefaultTCPMSS), |
| 91 max_congestion_window_(max_tcp_congestion_window * kDefaultTCPMSS), | 91 max_congestion_window_(max_tcp_congestion_window * kDefaultTCPMSS), |
| 92 pacing_rate_(QuicBandwidth::Zero()), | 92 pacing_rate_(QuicBandwidth::Zero()), |
| 93 pacing_gain_(1), | 93 pacing_gain_(1), |
| 94 congestion_window_gain_(1), | 94 congestion_window_gain_(1), |
| 95 congestion_window_gain_constant_( | 95 congestion_window_gain_constant_( |
| 96 static_cast<float>(base::GetFlag(FLAGS_quic_bbr_cwnd_gain))), | 96 static_cast<float>(GetQuicFlag(FLAGS_quic_bbr_cwnd_gain))), |
| 97 rtt_variance_weight_(static_cast<float>( | 97 rtt_variance_weight_( |
| 98 base::GetFlag(FLAGS_quic_bbr_rtt_variation_weight))), | 98 static_cast<float>(GetQuicFlag(FLAGS_quic_bbr_rtt_variation_weight))), |
| 99 num_startup_rtts_(kRoundTripsWithoutGrowthBeforeExitingStartup), | 99 num_startup_rtts_(kRoundTripsWithoutGrowthBeforeExitingStartup), |
| 100 cycle_current_offset_(0), | 100 cycle_current_offset_(0), |
| 101 last_cycle_start_(QuicTime::Zero()), | 101 last_cycle_start_(QuicTime::Zero()), |
| 102 is_at_full_bandwidth_(false), | 102 is_at_full_bandwidth_(false), |
| 103 rounds_without_bandwidth_gain_(0), | 103 rounds_without_bandwidth_gain_(0), |
| 104 bandwidth_at_last_round_(QuicBandwidth::Zero()), | 104 bandwidth_at_last_round_(QuicBandwidth::Zero()), |
| 105 exiting_quiescence_(false), | 105 exiting_quiescence_(false), |
| 106 exit_probe_rtt_at_(QuicTime::Zero()), | 106 exit_probe_rtt_at_(QuicTime::Zero()), |
| 107 probe_rtt_round_passed_(false), | 107 probe_rtt_round_passed_(false), |
| 108 last_sample_is_app_limited_(false), | 108 last_sample_is_app_limited_(false), |
| (...skipping 580 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 689 os << "Minimum RTT timestamp: " << state.min_rtt_timestamp.ToDebuggingValue() | 689 os << "Minimum RTT timestamp: " << state.min_rtt_timestamp.ToDebuggingValue() |
| 690 << std::endl; | 690 << std::endl; |
| 691 | 691 |
| 692 os << "Last sample is app-limited: " | 692 os << "Last sample is app-limited: " |
| 693 << (state.last_sample_is_app_limited ? "yes" : "no"); | 693 << (state.last_sample_is_app_limited ? "yes" : "no"); |
| 694 | 694 |
| 695 return os; | 695 return os; |
| 696 } | 696 } |
| 697 | 697 |
| 698 } // namespace net | 698 } // namespace net |
| OLD | NEW |