Index: net/quic/quic_ack_notifier.cc |
diff --git a/net/quic/quic_ack_notifier.cc b/net/quic/quic_ack_notifier.cc |
index b399a61bcc173541f22d65d49fe653caa6baa023..48ee23df1a45bac5c7ce4876489feb930fabfc36 100644 |
--- a/net/quic/quic_ack_notifier.cc |
+++ b/net/quic/quic_ack_notifier.cc |
@@ -29,21 +29,18 @@ QuicAckNotifier::QuicAckNotifier(DelegateInterface* delegate) |
QuicAckNotifier::~QuicAckNotifier() { |
} |
-void QuicAckNotifier::AddSequenceNumber( |
- const QuicPacketSequenceNumber& sequence_number, |
- int packet_payload_size) { |
+void QuicAckNotifier::OnSerializedPacket() { |
++unacked_packets_; |
- DVLOG(1) << "AckNotifier waiting for packet: " << sequence_number; |
} |
-bool QuicAckNotifier::OnAck(QuicPacketSequenceNumber sequence_number, |
- QuicTime::Delta delta_largest_observed) { |
+bool QuicAckNotifier::OnAck(QuicTime::Delta delta_largest_observed) { |
if (unacked_packets_ <= 0) { |
- LOG(DFATAL) << "Acked more packets than were tracked."; |
+ LOG(DFATAL) << "Acked more packets than were tracked." |
+ << " unacked_packets:" << unacked_packets_; |
return true; |
} |
--unacked_packets_; |
- if (IsEmpty()) { |
+ if (!HasUnackedPackets()) { |
// We have seen all the sequence numbers we were waiting for, trigger |
// callback notification. |
delegate_->OnAckNotification(retransmitted_packet_count_, |
@@ -54,6 +51,16 @@ bool QuicAckNotifier::OnAck(QuicPacketSequenceNumber sequence_number, |
return false; |
} |
+bool QuicAckNotifier::OnPacketAbandoned() { |
+ if (unacked_packets_ <= 0) { |
+ LOG(DFATAL) << "Abandoned more packets than were tracked." |
+ << " unacked_packets:" << unacked_packets_; |
+ return true; |
+ } |
+ --unacked_packets_; |
+ return unacked_packets_ == 0; |
+} |
+ |
void QuicAckNotifier::OnPacketRetransmitted(int packet_payload_size) { |
++retransmitted_packet_count_; |
retransmitted_byte_count_ += packet_payload_size; |