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

Side by Side Diff: net/quic/quic_sustained_bandwidth_recorder.cc

Issue 479443002: Not used in production. Add InRecovery() method to QUIC send algorithm (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@Add_flag_to_enable_BBR_73146298
Patch Set: Created 6 years, 4 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
OLDNEW
1 // Copyright (c) 2014 The Chromium Authors. All rights reserved. 1 // Copyright (c) 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/quic_sustained_bandwidth_recorder.h" 5 #include "net/quic/quic_sustained_bandwidth_recorder.h"
6 6
7 #include "base/logging.h" 7 #include "base/logging.h"
8 #include "net/quic/quic_bandwidth.h" 8 #include "net/quic/quic_bandwidth.h"
9 #include "net/quic/quic_time.h" 9 #include "net/quic/quic_time.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_(QuicBandwidth::Zero()), 17 bandwidth_estimate_(QuicBandwidth::Zero()),
17 max_bandwidth_estimate_(QuicBandwidth::Zero()), 18 max_bandwidth_estimate_(QuicBandwidth::Zero()),
18 max_bandwidth_timestamp_(0), 19 max_bandwidth_timestamp_(0),
19 start_time_(QuicTime::Zero()) {} 20 start_time_(QuicTime::Zero()) {}
20 21
21 void QuicSustainedBandwidthRecorder::RecordEstimate(bool is_reliable_estimate, 22 void QuicSustainedBandwidthRecorder::RecordEstimate(bool is_reliable_estimate,
23 bool in_slow_start,
22 QuicBandwidth bandwidth, 24 QuicBandwidth bandwidth,
23 QuicTime estimate_time, 25 QuicTime estimate_time,
24 QuicWallTime wall_time, 26 QuicWallTime wall_time,
25 QuicTime::Delta srtt) { 27 QuicTime::Delta srtt) {
26 if (!is_reliable_estimate) { 28 if (!is_reliable_estimate) {
27 is_recording_ = false; 29 is_recording_ = false;
28 DVLOG(1) << "Stopped recording due to unreliable estimate at: " 30 DVLOG(1) << "Stopped recording due to unreliable estimate at: "
29 << estimate_time.ToDebuggingValue(); 31 << estimate_time.ToDebuggingValue();
30 return; 32 return;
31 } 33 }
32 34
33 if (!is_recording_) { 35 if (!is_recording_) {
34 // This is the first estimate of a new recording period. 36 // This is the first estimate of a new recording period.
35 start_time_ = estimate_time; 37 start_time_ = estimate_time;
36 is_recording_ = true; 38 is_recording_ = true;
37 DVLOG(1) << "Started recording at: " << start_time_.ToDebuggingValue(); 39 DVLOG(1) << "Started recording at: " << start_time_.ToDebuggingValue();
38 return; 40 return;
39 } 41 }
40 42
41 // 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
42 // bandwidth estimate as a valid sustained bandwidth estimate. 44 // bandwidth estimate as a valid sustained bandwidth estimate.
43 if (estimate_time.Subtract(start_time_) >= srtt.Multiply(3)) { 45 if (estimate_time.Subtract(start_time_) >= srtt.Multiply(3)) {
44 has_estimate_ = true; 46 has_estimate_ = true;
47 bandwidth_estimate_recorded_during_slow_start_ = in_slow_start;
45 bandwidth_estimate_ = bandwidth; 48 bandwidth_estimate_ = bandwidth;
46 DVLOG(1) << "New sustained bandwidth estimate (KBytes/s): " 49 DVLOG(1) << "New sustained bandwidth estimate (KBytes/s): "
47 << bandwidth_estimate_.ToKBytesPerSecond(); 50 << bandwidth_estimate_.ToKBytesPerSecond();
48 } 51 }
49 52
50 // Check for an increase in max bandwidth. 53 // Check for an increase in max bandwidth.
51 if (bandwidth > max_bandwidth_estimate_) { 54 if (bandwidth > max_bandwidth_estimate_) {
52 max_bandwidth_estimate_ = bandwidth; 55 max_bandwidth_estimate_ = bandwidth;
53 max_bandwidth_timestamp_ = wall_time.ToUNIXSeconds(); 56 max_bandwidth_timestamp_ = wall_time.ToUNIXSeconds();
54 DVLOG(1) << "New max bandwidth estimate (KBytes/s): " 57 DVLOG(1) << "New max bandwidth estimate (KBytes/s): "
55 << max_bandwidth_estimate_.ToKBytesPerSecond(); 58 << max_bandwidth_estimate_.ToKBytesPerSecond();
56 } 59 }
57 } 60 }
58 61
59 } // namespace net 62 } // namespace net
OLDNEW
« no previous file with comments | « net/quic/quic_sustained_bandwidth_recorder.h ('k') | net/quic/quic_sustained_bandwidth_recorder_test.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698