Roll Chrome into Mojo.

net/quic/quic_packet_generator.h

 // 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.
 //
 // Responsible for generating packets on behalf of a QuicConnection.
 // Packets are serialized just-in-time.  Control frames are queued.
 // Ack and Feedback frames will be requested from the Connection
 // just-in-time.  When a packet needs to be sent, the Generator
 // will serialize a packet and pass it to QuicConnection::SendOrQueuePacket()
 //
@@ skipping 35 matching lines @@
 // mode, we should probably set a timer so that several independent
 // operations can be grouped into the same FEC group.
 //
 // When an FEC packet is generated, it will be send to the Delegate,
 // even if the Delegate has become unwritable after handling the
 // data packet immediately proceeding the FEC packet.
 
 #ifndef NET_QUIC_QUIC_PACKET_GENERATOR_H_
 #define NET_QUIC_QUIC_PACKET_GENERATOR_H_
 
+#include "net/quic/quic_ack_notifier.h"
 #include "net/quic/quic_packet_creator.h"
 #include "net/quic/quic_sent_packet_manager.h"
 #include "net/quic/quic_types.h"
 
 namespace net {
 
 namespace test {
 class QuicPacketGeneratorPeer;
 }  // namespace test
 
-class QuicAckNotifier;
-
 class NET_EXPORT_PRIVATE QuicPacketGenerator {
  public:
   class NET_EXPORT_PRIVATE DelegateInterface {
    public:
     virtual ~DelegateInterface() {}
     virtual bool ShouldGeneratePacket(TransmissionType transmission_type,
                                       HasRetransmittableData retransmittable,
                                       IsHandshake handshake) = 0;
     virtual QuicAckFrame* CreateAckFrame() = 0;
     virtual QuicCongestionFeedbackFrame* CreateFeedbackFrame() = 0;
@@ skipping 17 matching lines @@
   QuicPacketGenerator(QuicConnectionId connection_id,
                       QuicFramer* framer,
                       QuicRandom* random_generator,
                       DelegateInterface* delegate);
 
   virtual ~QuicPacketGenerator();
 
   // Called by the connection in the event of the congestion window changing.
   void OnCongestionWindowChange(QuicPacketCount max_packets_in_flight);
 
+  // Called by the connection when the RTT may have changed.
+  void OnRttChange(QuicTime::Delta rtt);
+
   // Indicates that an ACK frame should be sent.  If |also_send_feedback| is
   // true, then it also indicates a CONGESTION_FEEDBACK frame should be sent.
   // If |also_send_stop_waiting| is true, then it also indicates that a
   // STOP_WAITING frame should be sent as well.
   // The contents of the frame(s) will be generated via a call to the delegates
   // CreateAckFrame() and CreateFeedbackFrame() when the packet is serialized.
   void SetShouldSendAck(bool also_send_feedback,
                         bool also_send_stop_waiting);
 
   // Indicates that a STOP_WAITING frame should be sent.
   void SetShouldSendStopWaiting();
 
   void AddControlFrame(const QuicFrame& frame);
 
   // Given some data, may consume part or all of it and pass it to the
   // packet creator to be serialized into packets. If not in batch
-  // mode, these packets will also be sent during this call. Also
-  // attaches a QuicAckNotifier to any created stream frames, which
-  // will be called once the frame is ACKed by the peer. The
-  // QuicAckNotifier is owned by the QuicConnection. |notifier| may
-  // be nullptr.
+  // mode, these packets will also be sent during this call.
+  // |delegate| (if not nullptr) will be informed once all packets sent as a
+  // result of this call are ACKed by the peer.
   QuicConsumedData ConsumeData(QuicStreamId id,
                                const IOVector& data,
                                QuicStreamOffset offset,
                                bool fin,
                                FecProtection fec_protection,
-                               QuicAckNotifier* notifier);
+                               QuicAckNotifier::DelegateInterface* delegate);
 
   // Indicates whether batch mode is currently enabled.
   bool InBatchMode();
   // Disables flushing.
   void StartBatchOperations();
   // Enables flushing and flushes queued data which can be sent.
   void FinishBatchOperations();
 
   // Flushes all queued frames, even frames which are not sendable.
   void FlushAllQueuedFrames();
@@ skipping 36 matching lines @@
   QuicPacketSequenceNumber sequence_number() const;
 
   QuicByteCount max_packet_length() const;
 
   void set_max_packet_length(QuicByteCount length);
 
   void set_debug_delegate(DebugDelegate* debug_delegate) {
     debug_delegate_ = debug_delegate;
   }
 
+  QuicTime::Delta fec_timeout() { return fec_timeout_; }
+
  private:
   friend class test::QuicPacketGeneratorPeer;
 
   // Turn on FEC protection for subsequent packets in the generator.
   // If no FEC group is currently open in the creator, this method flushes any
   // queued frames in the generator and in the creator, and it then turns FEC on
   // in the creator. This method may be called with an open FEC group in the
   // creator, in which case, only the generator's state is altered.
   void MaybeStartFecProtection();
 
@@ skipping 21 matching lines @@
 
   DelegateInterface* delegate_;
   DebugDelegate* debug_delegate_;
 
   QuicPacketCreator packet_creator_;
   QuicFrames queued_control_frames_;
 
   // True if batch mode is currently enabled.
   bool batch_mode_;
 
+  // Timeout used for FEC alarm. Can be set to zero.
+  QuicTime::Delta fec_timeout_;
+
   // True if FEC protection is on. The creator may have an open FEC group even
   // if this variable is false.
   bool should_fec_protect_;
 
   // Flags to indicate the need for just-in-time construction of a frame.
   bool should_send_ack_;
   bool should_send_feedback_;
   bool should_send_stop_waiting_;
   // If we put a non-retransmittable frame (namley ack or feedback frame) in
   // this packet, then we have to hold a reference to it until we flush (and
   // serialize it). Retransmittable frames are referenced elsewhere so that they
   // can later be (optionally) retransmitted.
   scoped_ptr<QuicAckFrame> pending_ack_frame_;
   scoped_ptr<QuicCongestionFeedbackFrame> pending_feedback_frame_;
   scoped_ptr<QuicStopWaitingFrame> pending_stop_waiting_frame_;
 
   DISALLOW_COPY_AND_ASSIGN(QuicPacketGenerator);
 };
 
 }  // namespace net
 
 #endif  // NET_QUIC_QUIC_PACKET_GENERATOR_H_