| 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" | |
| 8 #include "net/quic/core/quic_bandwidth.h" | 7 #include "net/quic/core/quic_bandwidth.h" |
| 9 #include "net/quic/core/quic_time.h" | 8 #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 DVLOG(1) << "Stopped recording at: " << estimate_time.ToDebuggingValue(); | 30 QUIC_DVLOG(1) << "Stopped recording at: " |
| 31 << estimate_time.ToDebuggingValue(); |
| 31 return; | 32 return; |
| 32 } | 33 } |
| 33 | 34 |
| 34 if (!is_recording_) { | 35 if (!is_recording_) { |
| 35 // This is the first estimate of a new recording period. | 36 // This is the first estimate of a new recording period. |
| 36 start_time_ = estimate_time; | 37 start_time_ = estimate_time; |
| 37 is_recording_ = true; | 38 is_recording_ = true; |
| 38 DVLOG(1) << "Started recording at: " << start_time_.ToDebuggingValue(); | 39 QUIC_DVLOG(1) << "Started recording at: " << start_time_.ToDebuggingValue(); |
| 39 return; | 40 return; |
| 40 } | 41 } |
| 41 | 42 |
| 42 // If we have been recording for at least 3 * srtt, then record the latest | 43 // If we have been recording for at least 3 * srtt, then record the latest |
| 43 // bandwidth estimate as a valid sustained bandwidth estimate. | 44 // bandwidth estimate as a valid sustained bandwidth estimate. |
| 44 if (estimate_time - start_time_ >= 3 * srtt) { | 45 if (estimate_time - start_time_ >= 3 * srtt) { |
| 45 has_estimate_ = true; | 46 has_estimate_ = true; |
| 46 bandwidth_estimate_recorded_during_slow_start_ = in_slow_start; | 47 bandwidth_estimate_recorded_during_slow_start_ = in_slow_start; |
| 47 bandwidth_estimate_ = bandwidth; | 48 bandwidth_estimate_ = bandwidth; |
| 48 DVLOG(1) << "New sustained bandwidth estimate (KBytes/s): " | 49 QUIC_DVLOG(1) << "New sustained bandwidth estimate (KBytes/s): " |
| 49 << bandwidth_estimate_.ToKBytesPerSecond(); | 50 << bandwidth_estimate_.ToKBytesPerSecond(); |
| 50 } | 51 } |
| 51 | 52 |
| 52 // Check for an increase in max bandwidth. | 53 // Check for an increase in max bandwidth. |
| 53 if (bandwidth > max_bandwidth_estimate_) { | 54 if (bandwidth > max_bandwidth_estimate_) { |
| 54 max_bandwidth_estimate_ = bandwidth; | 55 max_bandwidth_estimate_ = bandwidth; |
| 55 max_bandwidth_timestamp_ = wall_time.ToUNIXSeconds(); | 56 max_bandwidth_timestamp_ = wall_time.ToUNIXSeconds(); |
| 56 DVLOG(1) << "New max bandwidth estimate (KBytes/s): " | 57 QUIC_DVLOG(1) << "New max bandwidth estimate (KBytes/s): " |
| 57 << max_bandwidth_estimate_.ToKBytesPerSecond(); | 58 << max_bandwidth_estimate_.ToKBytesPerSecond(); |
| 58 } | 59 } |
| 59 } | 60 } |
| 60 | 61 |
| 61 } // namespace net | 62 } // namespace net |
| OLD | NEW |