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

Nested and Inner Type Summary

Modifier and Type	Class and Description
public static enum	QuicEndpoint.ChannelType An enum identifying the type of channels used and supported by QuicEndpoint and QuicSelector
pack-priv abstract class	QuicEndpoint.ClosedConnection Represent a closing or draining quic connection: if we receive any packet for this connection we ignore them (if in draining state) or replay the closed packets in decreasing frequency: we reply to the first packet, then to the third, then to the seventh, etc...
pack-priv class	QuicEndpoint.ClosingConnection Represent a closing quic connection: if we receive any packet for this connection we simply replay the packet(s) that contained the ConnectionCloseFrame frame.
public static interface	QuicEndpoint.Datagram This interface represent a UDP Datagram.
pack-priv class	QuicEndpoint.DrainingConnection Represent a draining quic connection: if we receive any packet for this connection we simply ignore them.
public static record	QuicEndpoint.QuicDatagram An outgoing datagram, or an incoming datagram for which a connection was identified.
public static class	QuicEndpoint.QuicEndpointFactory
pack-priv static class	QuicEndpoint.QuicSelectableEndpoint A `QuicEndpoint` implementation based on non blocking Datagram Channels and using a NIO `Selector`.
pack-priv static class	QuicEndpoint.QuicVirtualThreadedEndpoint A `QuicEndpoint` implementation based on blocking Datagram Channels and using a Virtual Threads to poll the channel.
public static record	QuicEndpoint.SendStatelessReset A stateless reset that should be sent in response to an incoming datagram targeted at a deleted connection.
public static record	QuicEndpoint.StatelessReset An incoming datagram containing a stateless reset
private static record	QuicEndpoint.StatelessResetToken
public static record	QuicEndpoint.UnmatchedDatagram An incoming UDP Datagram for which no connection was found.

Modifier and Type	Field and Description
private final AtomicInteger	buffered
private final DatagramChannel	channel
private volatile boolean	closed
public static final QuicEndpoint.ChannelType	CONFIGURED_CHANNEL_TYPE The configured channel type
private final ConcurrentMap<QuicConnectionId, QuicPacketReceiver>	connections
pack-priv final Logger	debug
pack-priv static final boolean	DGRAM_SEND_ASYNC
pack-priv final Executor	executor
pack-priv volatile boolean	expectExceptions
private final QuicConnectionIdFactory	idFactory
private static final int	INCOMING_MAX_DATAGRAM
pack-priv static final int	MAX_BUFFERED_HIGH
pack-priv static final int	MAX_BUFFERED_LOW
private final String	name
private final ConcurrentMap<QuicEndpoint.StatelessResetToken, QuicPacketReceiver>	peerIssuedResetTokens
private final QuicInstance	quicInstance
pack-priv volatile boolean	readingStalled
pack-priv final SequentialScheduler	readLoopScheduler
pack-priv final ConcurrentLinkedQueue<QuicEndpoint.Datagram>	readQueue
private final ByteBuffer	receiveBuffer
pack-priv final QuicTimerQueue	timerQueue
private final Key	tokenEncryptionKey
private static final boolean	USE_NIO_SELECTOR
pack-priv static final Utils.UseVTForSelector	USE_VT_FOR_SELECTOR
pack-priv final SequentialScheduler	writeLoopScheduler
pack-priv final ConcurrentLinkedQueue<QuicEndpoint.QuicDatagram>	writeQueue

Access	Constructor and Description
private	QuicEndpoint(QuicInstance quicInstance, DatagramChannel channel, String name, QuicTimerQueue timerQueue)

Method Summary

Modifier and Type	Method and Description
public void	abort(Throwable error)
pack-priv void	abortConnection(QuicPacketReceiver c, Throwable error)
public boolean	Returns: true if connection ID was added, false otherwise addConnectionId(QuicConnectionId the connection ID to be added cid, QuicPacketReceiver the connection that should be mapped to the cid connection) Add the cid to connection mapping to the endpoint.
private static Stream<QuicConnectionId>	allConnectionIds(QuicPacketReceiver quicConnection)
private static ByteBuffer	allocateReceiveBuffer()
pack-priv void	associateStatelessResetToken(final byte[] the peer issued (16 byte) stateless reset token statelessResetToken, final QuicPacketReceiver the connection to link the token against connection) A peer issues a stateless reset token which it can then send to close the connection.
public int	buffer(int bytes)
public int	buffered()
pack-priv boolean	bufferTooBig()
public DatagramChannel	channel()
pack-priv void	channelReadLoop()
protected abstract QuicEndpoint.ChannelType	channelType()
protected QuicPacketReceiver	Returns: connection associated with the stateless token, or `null` checkStatelessReset(SocketAddress the sender's address source, final ByteBuffer datagram contents buffer) checks if the received datagram contains a stateless reset token; returns the associated connection if true, null otherwise
public void	close() Implements java.lang.AutoCloseable.close. Closes this resource, relinquishing any underlying resources.
pack-priv void	closeWriteQueue(Throwable t)
protected void	closing(QuicConnectionImpl connection, ByteBuffer datagram)
public final int	connectionCount()
private ByteBuffer	copyOnHeap(ByteBuffer buffer)
private static < the concrete endpoint type, one of `QuicSelectableEndpoint` or `QuicVirtualThreadedEndpoint` T extends QuicEndpoint> T	Returns: a new `QuicEndpoint` of the given `endpointType` create(Class<T> the concrete endpoint type, one of `QuicSelectableEndpoint.class` or `QuicVirtualThreadedEndpoint.class`. endpointType, QuicInstance the quic instance quicInstance, String the endpoint name name, SocketAddress the address to bind to bindAddress, QuicTimerQueue the timer queue timerQueue) Returns a new `QuicEndpoint` of the given `endpointType`.
public abstract void	detach() Detach the channel from the selector implementation
private void	detachAndCloseChannel()
public void	draining(final QuicConnectionImpl connection)
private void	dropPeerIssuedResetTokensFor(QuicPacketReceiver connection)
pack-priv QuicPacketReceiver	findQuicConnectionFor(SocketAddress peerAddress, ByteBuffer idbytes, boolean longHeaders)
pack-priv boolean	forceSendAsync()
pack-priv void	forgetStatelessResetToken(final byte[] The stateless reset token statelessResetToken) Discard the stateless reset token that this endpoint might have previously `associated any connection` with
public SocketAddress	getLocalAddress()
public String	getLocalAddressString()
pack-priv int	getMaxUdpPayloadSize()
public QuicConnectionIdFactory	idFactory()
public boolean	isChannelClosed()
private boolean	isClient()
pack-priv boolean	isClosed()
private boolean	isServer()
private QuicEndpoint.StatelessResetToken	makeToken(byte[] tokenBytes)
private QuicEndpoint.Datagram	Returns: a `Datagram` to be processed by the read loop if a match is found, or null if the datagram can be dropped immediately matchDatagram(SocketAddress the source address source, ByteBuffer the incoming datagram payload buffer) This method tries to figure out whether the received packet matches a connection, or a stateless reset.
public String	name()
private void	onReadError(Throwable t)
pack-priv void	onSendError(QuicEndpoint.QuicDatagram datagram, int tosend, IOException x)
pack-priv abstract void	pauseReading()
private ByteBuffer	peekConnectionBytes(QuicPacket.HeadersType headersType, ByteBuffer payload)
public void	pushClosedDatagram(QuicConnectionImpl the connection being closed connection, InetSocketAddress the peer address destination, ByteBuffer the datagram datagram) Called to schedule sending of a datagram that contains a single `ConnectionCloseFrame` sent in response to a `ConnectionClose` frame.
public void	pushClosingDatagram(QuicConnectionImpl the connection being closed connection, InetSocketAddress the peer address destination, ByteBuffer the datagram datagram) Called to schedule sending of a datagram that contains a `ConnectionCloseFrame`.
public void	pushDatagram(QuicPacketReceiver the source connection source, SocketAddress the destination address destination, ByteBuffer the encrypted datagram payload) Schedule a datagram for writing to the underlying channel.
private void	putConnection(QuicConnectionId id, QuicConnectionImpl quicConnection)
pack-priv boolean	readingPaused()
pack-priv void	readLoop()
public void	registerNewConnection(QuicConnectionImpl quicConnection)
public static void	registerWithSelector(QuicEndpoint the endpoint endpoint, QuicSelector<?> the selector selector, Logger a logger for debugging debug) Registers the given endpoint with the given selector.
private QuicEndpoint.ClosedConnection	remapClosing(QuicConnectionId id, QuicPacketReceiver conn, QuicEndpoint.ClosingConnection closingConnection)
private QuicEndpoint.DrainingConnection	remapDraining(QuicConnectionId id, QuicPacketReceiver conn, QuicEndpoint.DrainingConnection draining)
private void	remapPeerIssuedResetToken(QuicPacketReceiver newReceiver)
pack-priv void	removeConnection(final QuicPacketReceiver the connection to be removed connection) This will completely remove the connection from the endpoint.
public boolean	Returns: true if connection ID was removed, false otherwise removeConnectionId(QuicConnectionId the connection ID to be removed cid, QuicPacketReceiver the connection that is mapped to the cid connection) Remove the cid to connection mapping from the endpoint.
pack-priv abstract void	resumeReading()
private int	send(ByteBuffer datagram, SocketAddress destination)
private void	sendConnectionCloseQuietly(final QuicConnectionImpl quicConn)
pack-priv boolean	sendDatagram(QuicEndpoint.QuicDatagram datagram)
private void	silentTerminateConnection(QuicPacketReceiver c)
public QuicTimerQueue	Returns: the timer queue associated with this endpoint timer() Returns the timer queue associated with this endpoint.
protected TimeLine	Returns: the time source associated with this endpoint timeSource() Returns the time source associated with this endpoint.
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.
public int	unbuffer(int bytes)
protected void	unmatchedQuicPacket(QuicEndpoint.Datagram The datagram containing the packet datagram, QuicPacket.HeadersType The quic packet type headersType, ByteBuffer A buffer positioned at the start of the unmatched quic packet. The buffer may contain more coalesced quic packets. buffer) Called when parsing a quic packet that couldn't be matched to any registered connection.
pack-priv void	writeLoop()
private void	writeLoop0()
pack-priv Executor	writeLoopExecutor()

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

public abstract sealed Class QuicEndpoint

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary