// 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. // // The pure virtual class for send side congestion control algorithm. #ifndef NET_QUIC_CONGESTION_CONTROL_SEND_ALGORITHM_INTERFACE_H_ #define NET_QUIC_CONGESTION_CONTROL_SEND_ALGORITHM_INTERFACE_H_ #include #include "base/basictypes.h" #include "net/base/net_export.h" #include "net/quic/quic_bandwidth.h" #include "net/quic/quic_clock.h" #include "net/quic/quic_protocol.h" #include "net/quic/quic_time.h" namespace net { class NET_EXPORT_PRIVATE SendAlgorithmInterface { public: class SentPacket { public: SentPacket(QuicByteCount bytes, QuicTime timestamp) : bytes_sent_(bytes), send_timestamp_(timestamp) { } QuicByteCount BytesSent() { return bytes_sent_; } QuicTime& SendTimestamp() { return send_timestamp_; } private: QuicByteCount bytes_sent_; QuicTime send_timestamp_; }; typedef std::map SentPacketsMap; static SendAlgorithmInterface* Create(const QuicClock* clock, CongestionFeedbackType type); virtual ~SendAlgorithmInterface() {} // Called when we receive congestion feedback from remote peer. virtual void OnIncomingQuicCongestionFeedbackFrame( const QuicCongestionFeedbackFrame& feedback, QuicTime feedback_receive_time, const SentPacketsMap& sent_packets) = 0; // Called for each received ACK, with sequence number from remote peer. virtual void OnIncomingAck(QuicPacketSequenceNumber acked_sequence_number, QuicByteCount acked_bytes, QuicTime::Delta rtt) = 0; virtual void OnIncomingLoss(QuicTime ack_receive_time) = 0; // Inform that we sent x bytes to the wire, and if that was a retransmission. // Note: this function must be called for every packet sent to the wire. virtual void SentPacket(QuicTime sent_time, QuicPacketSequenceNumber sequence_number, QuicByteCount bytes, Retransmission is_retransmission) = 0; // Called when a packet is timed out. virtual void AbandoningPacket(QuicPacketSequenceNumber sequence_number, QuicByteCount abandoned_bytes) = 0; // Calculate the time until we can send the next packet. virtual QuicTime::Delta TimeUntilSend( QuicTime now, Retransmission is_retransmission, HasRetransmittableData has_retransmittable_data, IsHandshake handshake) = 0; // What's the current estimated bandwidth in bytes per second. // Returns 0 when it does not have an estimate. virtual QuicBandwidth BandwidthEstimate() = 0; // TODO(satyamshekhar): Monitor MinRtt. virtual QuicTime::Delta SmoothedRtt() = 0; // Get the send algorithm specific retransmission delay, called RTO in TCP, // Note 1: the caller is responsible for sanity checking this value. // Note 2: this will return zero if we don't have enough data for an estimate. virtual QuicTime::Delta RetransmissionDelay() = 0; }; } // namespace net #endif // NET_QUIC_CONGESTION_CONTROL_SEND_ALGORITHM_INTERFACE_H_