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