| 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 |