OLD | NEW |
1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 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/congestion_control/pacing_sender.h" | 5 #include "net/quic/congestion_control/pacing_sender.h" |
6 | 6 |
7 namespace net { | 7 namespace net { |
8 | 8 |
9 PacingSender::PacingSender(SendAlgorithmInterface* sender, | 9 PacingSender::PacingSender(SendAlgorithmInterface* sender, |
10 QuicTime::Delta alarm_granularity) | 10 QuicTime::Delta alarm_granularity) |
(...skipping 18 matching lines...) Expand all Loading... |
29 void PacingSender::OnIncomingQuicCongestionFeedbackFrame( | 29 void PacingSender::OnIncomingQuicCongestionFeedbackFrame( |
30 const QuicCongestionFeedbackFrame& feedback, | 30 const QuicCongestionFeedbackFrame& feedback, |
31 QuicTime feedback_receive_time, | 31 QuicTime feedback_receive_time, |
32 const SendAlgorithmInterface::SentPacketsMap& sent_packets) { | 32 const SendAlgorithmInterface::SentPacketsMap& sent_packets) { |
33 sender_->OnIncomingQuicCongestionFeedbackFrame( | 33 sender_->OnIncomingQuicCongestionFeedbackFrame( |
34 feedback, feedback_receive_time, sent_packets); | 34 feedback, feedback_receive_time, sent_packets); |
35 } | 35 } |
36 | 36 |
37 void PacingSender::OnPacketAcked( | 37 void PacingSender::OnPacketAcked( |
38 QuicPacketSequenceNumber acked_sequence_number, | 38 QuicPacketSequenceNumber acked_sequence_number, |
39 QuicByteCount acked_bytes, | 39 QuicByteCount acked_bytes) { |
40 QuicTime::Delta rtt) { | 40 sender_->OnPacketAcked(acked_sequence_number, acked_bytes); |
41 sender_->OnPacketAcked(acked_sequence_number, acked_bytes, rtt); | |
42 } | 41 } |
43 | 42 |
44 void PacingSender::OnPacketLost(QuicPacketSequenceNumber sequence_number, | 43 void PacingSender::OnPacketLost(QuicPacketSequenceNumber sequence_number, |
45 QuicTime ack_receive_time) { | 44 QuicTime ack_receive_time) { |
46 sender_->OnPacketLost(sequence_number, ack_receive_time); | 45 sender_->OnPacketLost(sequence_number, ack_receive_time); |
47 } | 46 } |
48 | 47 |
49 bool PacingSender::OnPacketSent( | 48 bool PacingSender::OnPacketSent( |
50 QuicTime sent_time, | 49 QuicTime sent_time, |
51 QuicPacketSequenceNumber sequence_number, | 50 QuicPacketSequenceNumber sequence_number, |
(...skipping 64 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
116 // Sent it immediately. The epoch end will be adjusted in OnPacketSent. | 115 // Sent it immediately. The epoch end will be adjusted in OnPacketSent. |
117 was_last_send_delayed_ = false; | 116 was_last_send_delayed_ = false; |
118 DVLOG(1) << "Sending packet now"; | 117 DVLOG(1) << "Sending packet now"; |
119 return QuicTime::Delta::Zero(); | 118 return QuicTime::Delta::Zero(); |
120 } | 119 } |
121 | 120 |
122 QuicBandwidth PacingSender::BandwidthEstimate() const { | 121 QuicBandwidth PacingSender::BandwidthEstimate() const { |
123 return sender_->BandwidthEstimate(); | 122 return sender_->BandwidthEstimate(); |
124 } | 123 } |
125 | 124 |
| 125 void PacingSender::UpdateRtt(QuicTime::Delta rtt_sample) { |
| 126 sender_->UpdateRtt(rtt_sample); |
| 127 } |
| 128 |
126 QuicTime::Delta PacingSender::SmoothedRtt() const { | 129 QuicTime::Delta PacingSender::SmoothedRtt() const { |
127 return sender_->SmoothedRtt(); | 130 return sender_->SmoothedRtt(); |
128 } | 131 } |
129 | 132 |
130 QuicTime::Delta PacingSender::RetransmissionDelay() const { | 133 QuicTime::Delta PacingSender::RetransmissionDelay() const { |
131 return sender_->RetransmissionDelay(); | 134 return sender_->RetransmissionDelay(); |
132 } | 135 } |
133 | 136 |
134 QuicByteCount PacingSender::GetCongestionWindow() const { | 137 QuicByteCount PacingSender::GetCongestionWindow() const { |
135 return sender_->GetCongestionWindow(); | 138 return sender_->GetCongestionWindow(); |
136 } | 139 } |
137 | 140 |
138 } // namespace net | 141 } // namespace net |
OLD | NEW |