Simplify QuicUnackedPacketMap's RemovePreviousTransmissions by always

net/quic/quic_unacked_packet_map.cc

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "net/quic/quic_unacked_packet_map.h"
 
 #include "base/logging.h"
 #include "base/stl_util.h"
 #include "net/quic/quic_connection_stats.h"
 #include "net/quic/quic_utils_chromium.h"
@@ skipping 89 matching lines @@
     transmission_info->all_transmissions->push_back(old_sequence_number);
   }
   transmission_info->all_transmissions->push_back(new_sequence_number);
   unacked_packets_.push_back(
       TransmissionInfo(frames,
                        transmission_info->sequence_number_length,
                        transmission_type,
                        transmission_info->all_transmissions));
 }
 
-void QuicUnackedPacketMap::ClearPreviousRetransmissions(size_t num_to_clear) {
-  while (!unacked_packets_.empty() && num_to_clear > 0) {
+void QuicUnackedPacketMap::ClearAllPreviousRetransmissions() {
+  while (!unacked_packets_.empty() && least_unacked_ < largest_observed_) {
     // If this packet is in flight, or has retransmittable data, then there is
     // no point in clearing out any further packets, because they would not
     // affect the high water mark.
     TransmissionInfo* info = &unacked_packets_.front();
     if (info->in_flight || info->retransmittable_frames != NULL) {
       break;
     }
 
     if (info->all_transmissions != NULL) {
       if (info->all_transmissions->size() < 2) {
         LOG(DFATAL) << "all_transmissions must be NULL or have multiple "
                     << "elements.  size:" << info->all_transmissions->size();
         delete info->all_transmissions;
       } else {
         info->all_transmissions->pop_front();
         if (info->all_transmissions->size() == 1) {
           // Set the newer transmission's 'all_transmissions' entry to NULL.
           QuicPacketSequenceNumber new_transmission =
               info->all_transmissions->front();
           TransmissionInfo* new_info =
               &unacked_packets_.at(new_transmission - least_unacked_);
           delete new_info->all_transmissions;
           new_info->all_transmissions = NULL;
         }
       }
     }
     unacked_packets_.pop_front();
     ++least_unacked_;
-    --num_to_clear;
   }
 }
 
 bool QuicUnackedPacketMap::HasRetransmittableFrames(
     QuicPacketSequenceNumber sequence_number) const {
   DCHECK_GE(sequence_number, least_unacked_);
   DCHECK_LT(sequence_number, least_unacked_ + unacked_packets_.size());
   return unacked_packets_[
       sequence_number - least_unacked_].retransmittable_frames != NULL;
 }
@@ skipping 198 matching lines @@
   TransmissionInfo* info = &unacked_packets_[sequence_number - least_unacked_];
   DCHECK(!info->in_flight);
   DCHECK_NE(0u, info->bytes_sent);
   DCHECK(info->sent_time.IsInitialized());
 
   bytes_in_flight_ += info->bytes_sent;
   info->in_flight = true;
 }
 
 }  // namespace net