| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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_sustained_bandwidth_recorder.h" | 5 #include "net/quic/core/quic_sustained_bandwidth_recorder.h" |
| 6 | 6 |
| 7 #include "base/logging.h" |
| 7 #include "net/quic/core/quic_bandwidth.h" | 8 #include "net/quic/core/quic_bandwidth.h" |
| 8 #include "net/quic/core/quic_time.h" | 9 #include "net/quic/core/quic_time.h" |
| 9 #include "net/quic/platform/api/quic_logging.h" | |
| 10 | 10 |
| 11 namespace net { | 11 namespace net { |
| 12 | 12 |
| 13 QuicSustainedBandwidthRecorder::QuicSustainedBandwidthRecorder() | 13 QuicSustainedBandwidthRecorder::QuicSustainedBandwidthRecorder() |
| 14 : has_estimate_(false), | 14 : has_estimate_(false), |
| 15 is_recording_(false), | 15 is_recording_(false), |
| 16 bandwidth_estimate_recorded_during_slow_start_(false), | 16 bandwidth_estimate_recorded_during_slow_start_(false), |
| 17 bandwidth_estimate_(QuicBandwidth::Zero()), | 17 bandwidth_estimate_(QuicBandwidth::Zero()), |
| 18 max_bandwidth_estimate_(QuicBandwidth::Zero()), | 18 max_bandwidth_estimate_(QuicBandwidth::Zero()), |
| 19 max_bandwidth_timestamp_(0), | 19 max_bandwidth_timestamp_(0), |
| 20 start_time_(QuicTime::Zero()) {} | 20 start_time_(QuicTime::Zero()) {} |
| 21 | 21 |
| 22 void QuicSustainedBandwidthRecorder::RecordEstimate(bool in_recovery, | 22 void QuicSustainedBandwidthRecorder::RecordEstimate(bool in_recovery, |
| 23 bool in_slow_start, | 23 bool in_slow_start, |
| 24 QuicBandwidth bandwidth, | 24 QuicBandwidth bandwidth, |
| 25 QuicTime estimate_time, | 25 QuicTime estimate_time, |
| 26 QuicWallTime wall_time, | 26 QuicWallTime wall_time, |
| 27 QuicTime::Delta srtt) { | 27 QuicTime::Delta srtt) { |
| 28 if (in_recovery) { | 28 if (in_recovery) { |
| 29 is_recording_ = false; | 29 is_recording_ = false; |
| 30 QUIC_DVLOG(1) << "Stopped recording at: " | 30 DVLOG(1) << "Stopped recording at: " << estimate_time.ToDebuggingValue(); |
| 31 << estimate_time.ToDebuggingValue(); | |
| 32 return; | 31 return; |
| 33 } | 32 } |
| 34 | 33 |
| 35 if (!is_recording_) { | 34 if (!is_recording_) { |
| 36 // This is the first estimate of a new recording period. | 35 // This is the first estimate of a new recording period. |
| 37 start_time_ = estimate_time; | 36 start_time_ = estimate_time; |
| 38 is_recording_ = true; | 37 is_recording_ = true; |
| 39 QUIC_DVLOG(1) << "Started recording at: " << start_time_.ToDebuggingValue(); | 38 DVLOG(1) << "Started recording at: " << start_time_.ToDebuggingValue(); |
| 40 return; | 39 return; |
| 41 } | 40 } |
| 42 | 41 |
| 43 // If we have been recording for at least 3 * srtt, then record the latest | 42 // If we have been recording for at least 3 * srtt, then record the latest |
| 44 // bandwidth estimate as a valid sustained bandwidth estimate. | 43 // bandwidth estimate as a valid sustained bandwidth estimate. |
| 45 if (estimate_time - start_time_ >= 3 * srtt) { | 44 if (estimate_time - start_time_ >= 3 * srtt) { |
| 46 has_estimate_ = true; | 45 has_estimate_ = true; |
| 47 bandwidth_estimate_recorded_during_slow_start_ = in_slow_start; | 46 bandwidth_estimate_recorded_during_slow_start_ = in_slow_start; |
| 48 bandwidth_estimate_ = bandwidth; | 47 bandwidth_estimate_ = bandwidth; |
| 49 QUIC_DVLOG(1) << "New sustained bandwidth estimate (KBytes/s): " | 48 DVLOG(1) << "New sustained bandwidth estimate (KBytes/s): " |
| 50 << bandwidth_estimate_.ToKBytesPerSecond(); | 49 << bandwidth_estimate_.ToKBytesPerSecond(); |
| 51 } | 50 } |
| 52 | 51 |
| 53 // Check for an increase in max bandwidth. | 52 // Check for an increase in max bandwidth. |
| 54 if (bandwidth > max_bandwidth_estimate_) { | 53 if (bandwidth > max_bandwidth_estimate_) { |
| 55 max_bandwidth_estimate_ = bandwidth; | 54 max_bandwidth_estimate_ = bandwidth; |
| 56 max_bandwidth_timestamp_ = wall_time.ToUNIXSeconds(); | 55 max_bandwidth_timestamp_ = wall_time.ToUNIXSeconds(); |
| 57 QUIC_DVLOG(1) << "New max bandwidth estimate (KBytes/s): " | 56 DVLOG(1) << "New max bandwidth estimate (KBytes/s): " |
| 58 << max_bandwidth_estimate_.ToKBytesPerSecond(); | 57 << max_bandwidth_estimate_.ToKBytesPerSecond(); |
| 59 } | 58 } |
| 60 } | 59 } |
| 61 | 60 |
| 62 } // namespace net | 61 } // namespace net |
| OLD | NEW |