Roll Chrome into Mojo.

net/quic/quic_packet_generator.cc

 // Copyright (c) 2012 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_packet_generator.h"
 
 #include "base/basictypes.h"
 #include "base/logging.h"
 #include "net/quic/quic_ack_notifier.h"
 #include "net/quic/quic_fec_group.h"
@@ skipping 159 matching lines @@
       NOT_RETRANSMISSION, HAS_RETRANSMITTABLE_DATA,
       has_handshake ? IS_HANDSHAKE : NOT_HANDSHAKE)) {
     QuicFrame frame;
     size_t bytes_consumed = packet_creator_.CreateStreamFrame(
         id, data, offset + total_bytes_consumed, fin, &frame);
     ++frames_created;
 
     // We want to track which packet this stream frame ends up in.
     if (FLAGS_quic_attach_ack_notifiers_to_packets) {
       if (notifier != nullptr) {
-        ack_notifiers_.insert(notifier);
+        ack_notifiers_.push_back(notifier);
       }
     } else {
       frame.stream_frame->notifier = notifier;
     }
 
     if (!AddFrame(frame)) {
       LOG(DFATAL) << "Failed to add stream frame.";
       // Inability to add a STREAM frame creates an unrecoverable hole in a
       // the stream, so it's best to close the connection.
       delegate_->CloseConnection(QUIC_INTERNAL_ERROR, false);
@@ skipping 29 matching lines @@
     delete notifier;
   }
 
   // Don't allow the handshake to be bundled with other retransmittable frames.
   if (has_handshake) {
     SendQueuedFrames(true);
   }
 
   // Try to close FEC group since we've either run out of data to send or we're
   // blocked. If not in batch mode, force close the group.
-  MaybeSendFecPacketAndCloseGroup(/*flush=*/false);
+  MaybeSendFecPacketAndCloseGroup(/*force=*/false);
 
   DCHECK(InBatchMode() || !packet_creator_.HasPendingFrames());
   return QuicConsumedData(total_bytes_consumed, fin_consumed);
 }
 
 bool QuicPacketGenerator::CanSendWithNextPendingFrameAddition() const {
   DCHECK(HasPendingFrames());
   HasRetransmittableData retransmittable =
       (should_send_ack_ || should_send_stop_waiting_)
           ? NO_RETRANSMITTABLE_DATA
@@ skipping 69 matching lines @@
 
 void QuicPacketGenerator::OnFecTimeout() {
   DCHECK(!InBatchMode());
   if (!ShouldSendFecPacket(true)) {
     LOG(DFATAL) << "No FEC packet to send on FEC timeout.";
     return;
   }
   // Flush out any pending frames in the generator and the creator, and then
   // send out FEC packet.
   SendQueuedFrames(true);
-  MaybeSendFecPacketAndCloseGroup(/*flush=*/true);
+  MaybeSendFecPacketAndCloseGroup(/*force=*/true);
 }
 
 QuicTime::Delta QuicPacketGenerator::GetFecTimeout(
     QuicPacketSequenceNumber sequence_number) {
   // Do not set up FEC alarm for |sequence_number| it is not the first packet in
   // the current group.
   if (packet_creator_.IsFecGroupOpen() &&
       (sequence_number == packet_creator_.fec_group_number())) {
     return QuicTime::Delta::Max(
         fec_timeout_, QuicTime::Delta::FromMilliseconds(kMinFecTimeoutMs));
@@ skipping 69 matching lines @@
   SerializedPacket serialized_packet = packet_creator_.SerializePacket();
   DCHECK(serialized_packet.packet);
 
   // There may be AckNotifiers interested in this packet.
   if (FLAGS_quic_attach_ack_notifiers_to_packets) {
     serialized_packet.notifiers.swap(ack_notifiers_);
     ack_notifiers_.clear();
   }
 
   delegate_->OnSerializedPacket(serialized_packet);
-  MaybeSendFecPacketAndCloseGroup(/*flush=*/false);
+  MaybeSendFecPacketAndCloseGroup(/*force=*/false);
 
   // The packet has now been serialized, safe to delete pending frames.
   pending_ack_frame_.reset();
   pending_stop_waiting_frame_.reset();
 }
 
 void QuicPacketGenerator::StopSendingVersion() {
   packet_creator_.StopSendingVersion();
 }
 
@@ skipping 38 matching lines @@
     packet_creator_.set_connection_id_length(PACKET_8BYTE_CONNECTION_ID);
   }
 }
 
 
 void QuicPacketGenerator::set_encryption_level(EncryptionLevel level) {
   packet_creator_.set_encryption_level(level);
 }
 
 }  // namespace net