Land Recent QUIC Changes until 03/09/2015.

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 282 matching lines @@
   DCHECK_GE(sequence_number, least_unacked_);
   DCHECK_LT(sequence_number, least_unacked_ + unacked_packets_.size());
   TransmissionInfo* info = &unacked_packets_[sequence_number - least_unacked_];
   if (info->in_flight) {
     LOG_IF(DFATAL, bytes_in_flight_ < info->bytes_sent);
     bytes_in_flight_ -= info->bytes_sent;
     info->in_flight = false;
   }
 }
 
+void QuicUnackedPacketMap::StopRetransmissionForStream(QuicStreamId stream_id) {
+  if (stream_id == kCryptoStreamId || stream_id == kHeadersStreamId) {
+    LOG(DFATAL) << "Special streams must always retransmit data: " << stream_id;
+    return;
+  }
+  QuicPacketSequenceNumber sequence_number = least_unacked_;
+  for (UnackedPacketMap::const_iterator it = unacked_packets_.begin();
+       it != unacked_packets_.end(); ++it, ++sequence_number) {
+    RetransmittableFrames* retransmittable_frames = it->retransmittable_frames;
+    if (!retransmittable_frames) {
+      continue;
+    }
+    retransmittable_frames->RemoveFramesForStream(stream_id);
+    if (retransmittable_frames->frames().empty()) {
+      RemoveRetransmittability(sequence_number);
+    }
+  }
+}
+
 bool QuicUnackedPacketMap::HasUnackedPackets() const {
   return !unacked_packets_.empty();
 }
 
 bool QuicUnackedPacketMap::HasInFlightPackets() const {
   return bytes_in_flight_ > 0;
 }
 
 const TransmissionInfo& QuicUnackedPacketMap::GetTransmissionInfo(
     QuicPacketSequenceNumber sequence_number) const {
@@ skipping 52 matching lines @@
     }
   }
   return false;
 }
 
 QuicPacketSequenceNumber QuicUnackedPacketMap::GetLeastUnacked() const {
   return least_unacked_;
 }
 
 }  // namespace net