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/inter_arrival_sender.h" | 5 #include "net/quic/congestion_control/inter_arrival_sender.h" |
6 | 6 |
7 namespace net { | 7 namespace net { |
8 | 8 |
9 namespace { | 9 namespace { |
10 const int64 kProbeBitrateKBytesPerSecond = 1200; // 9.6 Mbit/s | 10 const int64 kProbeBitrateKBytesPerSecond = 1200; // 9.6 Mbit/s |
(...skipping 243 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
254 QuicByteCount bytes, | 254 QuicByteCount bytes, |
255 TransmissionType /*transmission_type*/, | 255 TransmissionType /*transmission_type*/, |
256 HasRetransmittableData /*has_retransmittable_data*/) { | 256 HasRetransmittableData /*has_retransmittable_data*/) { |
257 if (probing_) { | 257 if (probing_) { |
258 probe_->OnPacketSent(bytes); | 258 probe_->OnPacketSent(bytes); |
259 } | 259 } |
260 paced_sender_->OnPacketSent(sent_time, bytes); | 260 paced_sender_->OnPacketSent(sent_time, bytes); |
261 return true; | 261 return true; |
262 } | 262 } |
263 | 263 |
264 void InterArrivalSender::OnRetransmissionTimeout() { | 264 void InterArrivalSender::OnRetransmissionTimeout( |
| 265 bool /*packets_retransmitted*/) { |
265 // TODO(ianswett): Decrease the available bandwidth. | 266 // TODO(ianswett): Decrease the available bandwidth. |
| 267 if (probing_) { |
| 268 probe_->OnRetransmissionTimeout(); |
| 269 } |
266 } | 270 } |
267 | 271 |
268 void InterArrivalSender::OnPacketAbandoned( | 272 void InterArrivalSender::OnPacketAbandoned( |
269 QuicPacketSequenceNumber /*sequence_number*/, | 273 QuicPacketSequenceNumber /*sequence_number*/, |
270 QuicByteCount abandoned_bytes) { | 274 QuicByteCount abandoned_bytes) { |
271 // TODO(pwestin): use for out outer_congestion_window_ logic. | 275 // TODO(pwestin): use for out outer_congestion_window_ logic. |
272 if (probing_) { | 276 if (probing_) { |
273 probe_->OnAcknowledgedPacket(abandoned_bytes); | 277 probe_->OnAcknowledgedPacket(abandoned_bytes); |
274 } | 278 } |
275 } | 279 } |
(...skipping 244 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
520 bitrate_ramp_up_->Reset(new_rate, current_bandwidth_, channel_estimate); | 524 bitrate_ramp_up_->Reset(new_rate, current_bandwidth_, channel_estimate); |
521 if (new_rate != current_bandwidth_) { | 525 if (new_rate != current_bandwidth_) { |
522 current_bandwidth_ = new_rate; | 526 current_bandwidth_ = new_rate; |
523 paced_sender_->UpdateBandwidthEstimate(feedback_receive_time, | 527 paced_sender_->UpdateBandwidthEstimate(feedback_receive_time, |
524 current_bandwidth_); | 528 current_bandwidth_); |
525 state_machine_->DecreaseBitrateDecision(); | 529 state_machine_->DecreaseBitrateDecision(); |
526 } | 530 } |
527 } | 531 } |
528 | 532 |
529 } // namespace net | 533 } // namespace net |
OLD | NEW |