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

Side by Side Diff: net/quic/congestion_control/inter_arrival_sender.cc

Issue 125253004: Simplify RTO interaction between the QUIC sent packet manager and the (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 6 years, 11 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 | Annotate | Revision Log
OLDNEW
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
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
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
OLDNEW
« no previous file with comments | « net/quic/congestion_control/inter_arrival_sender.h ('k') | net/quic/congestion_control/pacing_sender.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698