OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 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/quic_sent_packet_manager.h" | 5 #include "net/quic/quic_sent_packet_manager.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 | 8 |
9 #include "base/logging.h" | 9 #include "base/logging.h" |
10 #include "base/stl_util.h" | 10 #include "base/stl_util.h" |
(...skipping 543 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
554 QuicPacketSequenceNumber original_sequence_number, | 554 QuicPacketSequenceNumber original_sequence_number, |
555 QuicTime sent_time, | 555 QuicTime sent_time, |
556 QuicByteCount bytes, | 556 QuicByteCount bytes, |
557 TransmissionType transmission_type, | 557 TransmissionType transmission_type, |
558 HasRetransmittableData has_retransmittable_data) { | 558 HasRetransmittableData has_retransmittable_data) { |
559 QuicPacketSequenceNumber sequence_number = serialized_packet->sequence_number; | 559 QuicPacketSequenceNumber sequence_number = serialized_packet->sequence_number; |
560 DCHECK_LT(0u, sequence_number); | 560 DCHECK_LT(0u, sequence_number); |
561 DCHECK(!unacked_packets_.IsUnacked(sequence_number)); | 561 DCHECK(!unacked_packets_.IsUnacked(sequence_number)); |
562 LOG_IF(DFATAL, bytes == 0) << "Cannot send empty packets."; | 562 LOG_IF(DFATAL, bytes == 0) << "Cannot send empty packets."; |
563 | 563 |
564 if (original_sequence_number == 0) { | 564 if (original_sequence_number != 0) { |
565 if (!FLAGS_quic_ack_notifier_informed_on_serialized && | |
566 serialized_packet->retransmittable_frames) { | |
567 ack_notifier_manager_.OnSerializedPacket(*serialized_packet); | |
568 } | |
569 } else { | |
570 PendingRetransmissionMap::iterator it = | 565 PendingRetransmissionMap::iterator it = |
571 pending_retransmissions_.find(original_sequence_number); | 566 pending_retransmissions_.find(original_sequence_number); |
572 if (it != pending_retransmissions_.end()) { | 567 if (it != pending_retransmissions_.end()) { |
573 pending_retransmissions_.erase(it); | 568 pending_retransmissions_.erase(it); |
574 } else { | 569 } else { |
575 DLOG(DFATAL) << "Expected sequence number to be in " | 570 DLOG(DFATAL) << "Expected sequence number to be in " |
576 << "pending_retransmissions_. sequence_number: " | 571 << "pending_retransmissions_. sequence_number: " |
577 << original_sequence_number; | 572 << original_sequence_number; |
578 } | 573 } |
579 // Inform the ack notifier of retransmissions so it can calculate the | 574 // Inform the ack notifier of retransmissions so it can calculate the |
(...skipping 430 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1010 // Set up a pacing sender with a 1 millisecond alarm granularity, the same as | 1005 // Set up a pacing sender with a 1 millisecond alarm granularity, the same as |
1011 // the default granularity of the Linux kernel's FQ qdisc. | 1006 // the default granularity of the Linux kernel's FQ qdisc. |
1012 using_pacing_ = true; | 1007 using_pacing_ = true; |
1013 send_algorithm_.reset( | 1008 send_algorithm_.reset( |
1014 new PacingSender(send_algorithm_.release(), | 1009 new PacingSender(send_algorithm_.release(), |
1015 QuicTime::Delta::FromMilliseconds(1), | 1010 QuicTime::Delta::FromMilliseconds(1), |
1016 kInitialUnpacedBurst)); | 1011 kInitialUnpacedBurst)); |
1017 } | 1012 } |
1018 | 1013 |
1019 } // namespace net | 1014 } // namespace net |
OLD | NEW |