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