* Note that we need to track the ACK of outgoing packets that * contain ACK frames in order to figure out whether a peer * knows that a particular packet number has been received and * avoid retransmission. However - we don't want ACK frames to grow * too big and therefore we can drop some of the information, * based on the largestSentAckedPN - see RFC 9000 Section 13.2 * */ long getMinPNThreshold(); /** * {@return a new packet number atomically allocated in this space} */ long allocateNextPN(); /** * This method is called by {@link QuicConnectionImpl} upon reception of * and successful negotiation of a new version. * In that case we should stop retransmitting packet that have the * "wrong" version: they will never be acknowledged. */ void versionChanged(); /** * This method is called by {@link QuicConnectionImpl} upon reception of * and successful processing of retry packet. * In that case we should treat all previously sent packets as lost. */ void retry(); /** * {@return a lock used by the transmission task}. * Used to ensure that the transmission task does not observe partial changes * during processing of incoming Versions and Retry packets. */ ReentrantLock getTransmitLock(); /** * Called when a packet is received. Causes the next ack frame to be * updated. If a packet contains an {@link AckFrame}, the caller is * expected to also later call {@link #processAckFrame(AckFrame)} * when processing the packet payload. * * @param packet the received packet * @param packetNumber the received packet number * @param isAckEliciting whether this packet is ack eliciting */ void packetReceived(PacketType packet, long packetNumber, boolean isAckEliciting); /** * Signals that a packet has been sent. * This method is called by {@link QuicConnectionImpl} when a packet has been * pushed to the endpoint for sending. *
The retransmitted packet is taken out the pendingRetransmission list and
* the new packet is inserted in the pendingAcknowledgement list.
*
* @param packet the new packet being retransmitted
* @param previousPacketNumber the packet number of the previous packet that was not acknowledged,
* or -1 if this is not a retransmission
* @param packetNumber the new packet number under which this packet is being retransmitted
* @throws IllegalArgumentException If {@code newPacketNumber} is lesser than 0
*/
void packetSent(QuicPacket packet, long previousPacketNumber, long packetNumber);
/**
* Processes a received ACK frame.
* This method is called by {@link QuicConnectionImpl}.
*
* @param frame the ACK frame received.
*/
void processAckFrame(AckFrame frame) throws QuicTransportException;
/**
* Signals that the peer confirmed the handshake. Application space only.
*/
void confirmHandshake();
/**
* Get the next ack frame to send.
* This method returns the prepared ack frame if:
* - it was not sent yet
* - there are new ack-eliciting packets to acknowledge
* - optionally, if the ack frame is overdue
*
* @param onlyOverdue if true, the frame will only be returned if it's overdue
* @return The next AckFrame to send to the peer, or {@code null}
* if there is nothing to acknowledge.
*/
AckFrame getNextAckFrame(boolean onlyOverdue);
/**
* Get the next ack frame to send.
* This method returns the prepared ack frame if:
* - it was not sent yet
* - there are new ack-eliciting packets to acknowledge
* - the ack frame size doesn't exceed {@code maxSize}
* - optionally, if the ack frame is overdue
*
* @param onlyOverdue if true, the frame will only be returned if it's overdue
* @param maxSize
* @return The next AckFrame to send to the peer, or {@code null}
* if there is nothing to acknowledge.
*/
AckFrame getNextAckFrame(boolean onlyOverdue, int maxSize);
/**
* Used to request sending of a ping frame, for instance, to verify that
* the connection is alive.
* @return a completable future that will be completed with the time it
* took, in milliseconds, for the peer to acknowledge the packet that
* contained the PingFrame (or any packet that was sent after)
*
* @apiNote The returned completable future is actually completed
* if any packet whose packet number is greater than the packet number
* that contained the ping frame is acknowledged.
*/
CompletableFuture