OpenJDK 27 · jdk.internal.net.http.quic.PacketSpaceManager

Modifier and Type	Class and Description
private class	PacketSpaceManager.EmittedAckTracker A class to keep track of the largest packet that was acknowledged by a packet that is being acknowledged.
private static class	PacketSpaceManager.Handles
pack-priv static class	PacketSpaceManager.HandshakePacketSpaceManager
pack-priv static record	PacketSpaceManager.NextAckFrame A record that stores the next AckFrame that should be sent within this packet number space.
pack-priv static class	PacketSpaceManager.OneRttPacketSpaceManager
pack-priv class	PacketSpaceManager.PacketTransmissionTask A task that sends packets to the peer.
private static record	PacketSpaceManager.PendingAcknowledgement A record to store a packet that hasn't been acknowledged, and should be scheduled for retransmission if not acknowledged when the deadline is reached.
private static record	PacketSpaceManager.PingRequest A record used to implement `requestSendPing()`.
private static record	PacketSpaceManager.PreviousNumbers A record to store previous numbers with which a packet has been retransmitted.

Modifier and Type	Field and Description
public static final int	ACK_DELAY_EXPONENT
public static final int	ADVERTISED_MAX_ACK_DELAY
private volatile boolean	blockedByCC
private volatile boolean	blockedByPacer
pack-priv volatile boolean	closed
private final QuicCongestionController	congestionController
protected final Logger	debug
private final Supplier<String>	debugStrSupplier
private final PacketSpaceManager.EmittedAckTracker	emittedAckTracker
private volatile boolean	fastRetransmit
private volatile boolean	fastRetransmitDone
private long	handshakeConfirmedPN
private final TimeLine	instantSource
private static final long	kPacketThreshold
private static final int	kPersistentCongestionThreshold
private volatile long	largestAckedPNReceivedByPeer
private volatile long	largestAckElicitingReceivedPN
private volatile long	largestAckElicitingSentPN
private volatile long	largestProcessedPN
private volatile long	largestReceivedAckedPN
private volatile long	largestSentAckedPN
private volatile Deadline	lastAckElicitingTime
private final ConcurrentLinkedQueue<PacketSpaceManager.PendingAcknowledgement>	lostPackets
public static final int	MAX_ACK_DELAY
public static final int	MAX_ACKRANGE_COUNT_BEFORE_PING
private final long	maxAckDelay
private volatile PacketSpaceManager.NextAckFrame	nextAckFrame
private final AtomicLong	nextPN
private final PacketEmitter	packetEmitter
private final QuicPacket.PacketNumberSpace	packetNumberSpace
private final PacketSpaceManager.PacketTransmissionTask	packetTransmissionTask
private volatile long	peerAckDelayExponent
private volatile long	peerMaxAckDelayMillis
private final ConcurrentLinkedQueue<PacketSpaceManager.PendingAcknowledgement>	pendingAcknowledgements
private final ConcurrentLinkedQueue<PacketSpaceManager.PingRequest>	pendingPingRequests
private final ConcurrentLinkedQueue<PacketSpaceManager.PendingAcknowledgement>	pendingRetransmission
private volatile CompletableFuture<Long>	pingRequested
private final QuicTLSEngine	quicTLSEngine
private final QuicRttEstimator	rttEstimator
private final ConcurrentSkipListMap<Long, Deadline>	sendTimes
public static final int	TIMER_DELAY
private final ReentrantLock	transferLock
private final ReentrantLock	transmitLock
private volatile boolean	transmitNow
private final ConcurrentLinkedQueue<PacketSpaceManager.PendingAcknowledgement>	triggeredForRetransmission

Access	Constructor and Description
public	PacketSpaceManager(final QuicConnectionImpl The connection for which this manager is created. connection, final QuicPacket.PacketNumberSpace The packet number space. packetNumberSpace) Creates a new `PacketSpaceManager` for the given packet number space.
public	PacketSpaceManager(QuicPacket.PacketNumberSpace the packet number space. packetNumberSpace, PacketEmitter the packet emitter packetEmitter, TimeLine instantSource, QuicRttEstimator rttEstimator, QuicCongestionController the congestion controller congestionController, QuicTLSEngine quicTLSEngine, Supplier<String> a supplier for a debug tag to use for logging purposes debugStrSupplier) Creates a new `PacketSpaceManager` for the given packet number space.

Method Summary

Modifier and Type	Method and Description
private long	ackElicitingPacketProcessed(long packetNumber)
private void	addAcknowledgement(PacketSpaceManager.PendingAcknowledgement ack)
private void	addToAckFrame(long packetNumber, boolean isAckEliciting)
public long	allocateNextPN() Implements jdk.internal.net.http.quic.packets.PacketSpace.allocateNextPN. Returns a new packet number atomically allocated in this space.
private void	cleanupAcks()
private void	clearAll()
public void	close() Implements jdk.internal.net.http.quic.packets.PacketSpace.close. Stops retransmission for this packet space.
private Deadline	computeNewDeadlineFor(AckFrame frame, Deadline now, Deadline deadline, long packetNumber, long previousLargest, long ackDelay)
public Deadline	Returns: the deadline at which the scheduler's task for this packet space should be scheduled to wake up computeNextDeadline() Computes the next deadline for generating a non ACK eliciting packet containing the next ACK frame, or for retransmitting unacknowledged packets for which retransmission is due.
public Deadline	computeNextDeadline(boolean verbose)
public void	confirmHandshake() Implements jdk.internal.net.http.quic.packets.PacketSpace.confirmHandshake. Signals that the peer confirmed the handshake.
pack-priv Deadline	deadline()
pack-priv void	debugState()
pack-priv void	debugState(String prefix, StringBuilder sb)
private int	detectAndRemoveLostPackets(Deadline current time, used for time-based loss detection. now) Returns the count of unacknowledged packets that were declared lost.
private long	Returns: the packet number of the emitted packet emitAckPacket(AckFrame The ACK frame to send. ackFrame, boolean sendPing) Called by the `PacketTransmissionTask` to generate a non ACK eliciting packet containing only the given ACK frame.
public void	fastRetransmit() Implements jdk.internal.net.http.quic.packets.PacketSpace.fastRetransmit. Immediately retransmit one unacknowledged initial packet
public long	getLargestPeerAckedPN() Implements jdk.internal.net.http.quic.packets.PacketSpace.getLargestPeerAckedPN. The largest received acked PN is used to compute the packet number that we include in an outgoing Quic packet.
public long	getLargestProcessedPN() Implements jdk.internal.net.http.quic.packets.PacketSpace.getLargestProcessedPN. The largest processed PN is used to compute the packet number of an incoming Quic packet.
public long	getLargestSentAckedPN() Implements jdk.internal.net.http.quic.packets.PacketSpace.getLargestSentAckedPN. Returns the largest packet number that we have acknowledged in this space.
private Deadline	getLossTimer()
public long	Returns: the max delay before emitting a non ACK-eliciting packet to acknowledge a received ACK-eliciting packet, in milliseconds getMaxAckDelay() Returns the max delay before emitting a non ACK-eliciting packet to acknowledge a received ACK-eliciting packet, in milliseconds.
public long	getMinPNThreshold() Implements jdk.internal.net.http.quic.packets.PacketSpace.getMinPNThreshold. Returns the packet number threshold below which packets should be discarded without being processed in this space.
private PacketSpaceManager.NextAckFrame	getNextAck(boolean onlyOverdue, int maxSize)
public AckFrame	getNextAckFrame(boolean onlyOverdue) Implements jdk.internal.net.http.quic.packets.PacketSpace.getNextAckFrame. Get the next ack frame to send.
public AckFrame	getNextAckFrame(boolean onlyOverdue, int maxSize) Implements jdk.internal.net.http.quic.packets.PacketSpace.getNextAckFrame. Get the next ack frame to send.
public AtomicLong	getNextPN()
public long	Returns: the max ACK delay of the peer, in milliseconds getPeerMaxAckDelayMillis() Returns the max ACK delay of the peer, in milliseconds.
pack-priv Duration	getPersistentCongestionDuration()
private Deadline	getPtoDeadline()
pack-priv Duration	getPtoDuration()
public ReentrantLock	getTransmitLock() Implements jdk.internal.net.http.quic.packets.PacketSpace.getTransmitLock. Returns a lock used by the transmission task.
public boolean	isAcknowledged(long packetNumber) Implements jdk.internal.net.http.quic.packets.PacketSpace.isAcknowledged. Returns true if a packet with that packet number is already being acknowledged (will be, or has been acknowledged).
private boolean	isAcknowledgingLostPacket(PacketSpaceManager.PendingAcknowledgement pending, AckFrame frame, List<PacketSpaceManager.PendingAcknowledgement>[] recovered)
private boolean	isApplicationSpace()
public boolean	isClosed() Implements jdk.internal.net.http.quic.packets.PacketSpace.isClosed. Returns true if this packet space is closed.
pack-priv boolean	isClosing(QuicPacket packet)
private boolean	Returns: true if this packet space isn't closed and if the underlying packet emitter is open, else returns false isOpenForTransmission() Returns true if this packet space isn't closed and if the underlying packet emitter is open, else returns false.
private boolean	Returns: true if PTO timer expired, false otherwise isPTO(Deadline now) Returns true if PTO timer expired, false otherwise.
private boolean	largestAckReceived(long packetNumber)
private long	largestAckSent(long packetNumber)
private synchronized void	lastAckElicitingSent(long packetNumber)
private Deadline	lastAckElicitingSent(Deadline now)
private static Deadline	min(Deadline one, Deadline two)
public Deadline	Returns: the next deadline at which the scheduler's task for this packet space is currently scheduled to wake up nextScheduledDeadline() Returns the next deadline at which the scheduler's task for this packet space is currently scheduled to wake up.
private Deadline	now()
public QuicPacket.PacketNumberSpace	packetNumberSpace() Implements jdk.internal.net.http.quic.packets.PacketSpace.packetNumberSpace. Returns the packet number space managed by this class.
private long	packetProcessed(long packetNumber)
public void	packetReceived(QuicPacket.PacketType packet, long packetNumber, boolean isAckEliciting) Implements jdk.internal.net.http.quic.packets.PacketSpace.packetReceived. Called when a packet is received.
public void	packetSent(QuicPacket packet, long previousPacketNumber, long packetNumber) Implements jdk.internal.net.http.quic.packets.PacketSpace.packetSent. Signals that a packet has been sent.
pack-priv QuicPacket.PacketType	packetType()
private long	peerAckDelayToMicros(long ackDelay)
public <T> T	pendingAcknowledgements(Function<LongStream, T> walker)
public <T> T	pendingRetransmission(Function<LongStream, T> walker)
public void	processAckFrame(AckFrame frame) Implements jdk.internal.net.http.quic.packets.PacketSpace.processAckFrame. Processes a received ACK frame.
private void	processPingResponses(long the acknowledged packet number packetNumber) Theoretically we should wait for the packet that contains the ping frame to be acknowledged, but if we receive the ack of a packet with a larger number, we can assume that the connection is still alive, and therefore complete the ping response.
pack-priv Deadline	prospectiveDeadline()
private void	purgeSendTimes(long largestAcknowledged)
private void	registerPingRequest(PacketSpaceManager.PingRequest pingRequest)
public CompletableFuture<Long>	Returns: 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) requestSendPing() Implements jdk.internal.net.http.quic.packets.PacketSpace.requestSendPing. Used to request sending of a ping frame, for instance, to verify that the connection is alive.
private boolean	retransmit()
private void	retransmitPTO()
public void	retry() Implements jdk.internal.net.http.quic.packets.PacketSpace.retry. This method is called by `QuicConnectionImpl` upon reception of and successful processing of retry packet.
public void	runTransmitter() Implements jdk.internal.net.http.quic.packets.PacketSpace.runTransmitter. Triggers immediate run of transmit loop.
private boolean	shouldSendPing(Deadline now, AckFrame frame)
private QuicTLSEngine.KeySpace	tlsEncryptionLevel() returns the TLS encryption level of this packet space as specified in RFC-9001, section 4, table 1.
private boolean	Returns: whether the given pending unacknowledged packet is being acknowledged by this ack frame. trackAcknowlegment(PacketSpaceManager.PendingAcknowledgement a yet unacknowledged packet that may be acknowledged by the given`AckFrame`. pending, AckFrame a received `AckFrame` frame) Tracks the largest packet acknowledged by the packets acknowledged in the given AckFrame.
public <T> T	triggeredForRetransmission(Function<LongStream, T> walker)
public void	updatePeerTransportParameters(long the new delay, in milliseconds peerDelay, long the new ack delay exponent ackDelayExponent) Implements jdk.internal.net.http.quic.packets.PacketSpace.updatePeerTransportParameters. Changes the value of the peer max ACK delay and ack delay exponent
public void	versionChanged() Implements jdk.internal.net.http.quic.packets.PacketSpace.versionChanged. This method is called by `QuicConnectionImpl` upon reception of and successful negotiation of a new version.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

public sealed Class PacketSpaceManager

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary