| 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 485 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 496 SerializedPacket* serialized_packet, | 496 SerializedPacket* serialized_packet, |
| 497 QuicPacketSequenceNumber original_sequence_number, | 497 QuicPacketSequenceNumber original_sequence_number, |
| 498 QuicTime sent_time, | 498 QuicTime sent_time, |
| 499 QuicByteCount bytes, | 499 QuicByteCount bytes, |
| 500 TransmissionType transmission_type, | 500 TransmissionType transmission_type, |
| 501 HasRetransmittableData has_retransmittable_data) { | 501 HasRetransmittableData has_retransmittable_data) { |
| 502 QuicPacketSequenceNumber sequence_number = serialized_packet->sequence_number; | 502 QuicPacketSequenceNumber sequence_number = serialized_packet->sequence_number; |
| 503 DCHECK_LT(0u, sequence_number); | 503 DCHECK_LT(0u, sequence_number); |
| 504 DCHECK(!unacked_packets_.IsUnacked(sequence_number)); | 504 DCHECK(!unacked_packets_.IsUnacked(sequence_number)); |
| 505 LOG_IF(DFATAL, bytes == 0) << "Cannot send empty packets."; | 505 LOG_IF(DFATAL, bytes == 0) << "Cannot send empty packets."; |
| 506 if (debug_delegate_ != nullptr) { | |
| 507 debug_delegate_->OnSentPacket(*serialized_packet, | |
| 508 original_sequence_number, | |
| 509 sent_time, | |
| 510 bytes, | |
| 511 transmission_type); | |
| 512 } | |
| 513 | 506 |
| 514 if (original_sequence_number == 0) { | 507 if (original_sequence_number == 0) { |
| 515 if (serialized_packet->retransmittable_frames) { | 508 if (serialized_packet->retransmittable_frames) { |
| 516 ack_notifier_manager_.OnSerializedPacket(*serialized_packet); | 509 ack_notifier_manager_.OnSerializedPacket(*serialized_packet); |
| 517 } | 510 } |
| 518 unacked_packets_.AddPacket(*serialized_packet); | 511 unacked_packets_.AddPacket(*serialized_packet); |
| 519 serialized_packet->retransmittable_frames = nullptr; | 512 serialized_packet->retransmittable_frames = nullptr; |
| 520 } else { | 513 } else { |
| 521 OnRetransmittedPacket(original_sequence_number, sequence_number); | 514 OnRetransmittedPacket(original_sequence_number, sequence_number); |
| 522 } | 515 } |
| (...skipping 357 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 880 | 873 |
| 881 // Set up a pacing sender with a 5 millisecond alarm granularity. | 874 // Set up a pacing sender with a 5 millisecond alarm granularity. |
| 882 using_pacing_ = true; | 875 using_pacing_ = true; |
| 883 send_algorithm_.reset( | 876 send_algorithm_.reset( |
| 884 new PacingSender(send_algorithm_.release(), | 877 new PacingSender(send_algorithm_.release(), |
| 885 QuicTime::Delta::FromMilliseconds(5), | 878 QuicTime::Delta::FromMilliseconds(5), |
| 886 kInitialUnpacedBurst)); | 879 kInitialUnpacedBurst)); |
| 887 } | 880 } |
| 888 | 881 |
| 889 } // namespace net | 882 } // namespace net |
| OLD | NEW |