Modifier and Type	Class and Description
pack-priv static class	QuicSelector.QuicNioSelector A `QuicSelector` implementation based on non-blocking Datagram Channels and using a NIO `Selector`.
private static record	QuicSelector.QuicSelectorThread
pack-priv static class	QuicSelector.QuicVirtualThreadPoller A `QuicSelector` implementation based on blocking Datagram Channels and using a Virtual Threads to poll the channels.

Modifier and Type	Field and Description
pack-priv final Logger	debug
private volatile boolean	done
public static final long	IDLE_PERIOD_MS The maximum timeout passed to Selector::select.
private final QuicInstance	instance
private static final ScopedValue<Boolean>	IS_SELECTOR
private final String	name
private static final TimeLine	source
private final QuicSelector.QuicSelectorThread	thread
private final QuicTimerQueue	timerQueue

Access	Constructor and Description
private	QuicSelector(QuicInstance instance, String name)

Method Summary

Modifier and Type	Method and Description
public void	abort(Throwable t)
public void	awaitTermination(long the maximum time to wait for termination timeout, TimeUnit the timeout unit unit) Awaits termination of the selector thread, up until the given timeout has elapsed.
public void	close() Implements java.lang.AutoCloseable.close. Closes this `QuicSelector`.
public long	computeNextDeadLine()
public static QuicSelector<? extends QuicEndpoint>	Returns: a new instance of `QuicNioSelector` createQuicNioSelector(QuicInstance the quic instance quicInstance, String the selector name name) Returns a new instance of `QuicNioSelector`.
public static QuicSelector<? extends QuicEndpoint>	Returns: a new instance of `QuicVirtualThreadPoller` createQuicVirtualThreadPoller(QuicInstance the quic instance quicInstance, String the selector name name) Returns a new instance of `QuicVirtualThreadPoller`.
pack-priv boolean	done()
public static boolean	isSelectorThread()
public String	name()
public void	register(T endpoint)
public final void	run() Implements java.lang.Runnable.run. Runs this operation.
pack-priv abstract void	runSelector()
public void	shutdown() Shuts down the `QuicSelector` by invoking `Selector#close()`.
public void	start()
public QuicTimerQueue	timer()
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.
public void	wakeup()

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

Field Detail

debug	back to summary
pack-priv final Logger debug

done	back to summary
private volatile boolean done

IDLE_PERIOD_MS	back to summary
public static final long IDLE_PERIOD_MS The maximum timeout passed to Selector::select.

instance	back to summary
private final QuicInstance instance

IS_SELECTOR	back to summary
private static final ScopedValue<Boolean> IS_SELECTOR

name	back to summary
private final String name

source	back to summary
private static final TimeLine source

thread	back to summary
private final QuicSelector.QuicSelectorThread thread

timerQueue	back to summary
private final QuicTimerQueue timerQueue

QuicSelector	back to summary
private QuicSelector(QuicInstance instance, String name)

Method Detail

abort	back to summary
public void abort(Throwable t)

awaitTermination	back to summary
public void awaitTermination(long timeout, TimeUnit unit) Awaits termination of the selector thread, up until the given timeout has elapsed. If the current thread is the selector thread, returns immediately without waiting. Parameters timeout:long the maximum time to wait for termination unit:TimeUnit the timeout unit

awaitTermination

back to summary

public void awaitTermination(long timeout, TimeUnit unit)

Awaits termination of the selector thread, up until the given timeout has elapsed. If the current thread is the selector thread, returns immediately without waiting.

Parameters

timeout:long: the maximum time to wait for termination
unit:TimeUnit: the timeout unit

close back to summary

close	back to summary
public void close() Implements java.lang.AutoCloseable.close. Closes this `QuicSelector`. This method calls `shutdown()` and then waits for the selector thread to terminate, up to two `IDLE_PERIOD_MS`. Annotations @Override

public void close()

Implements java.lang.AutoCloseable.close.

Closes this QuicSelector. This method calls shutdown() and then waits for the selector thread to terminate, up to two IDLE_PERIOD_MS.

Annotations

@Override

computeNextDeadLine	back to summary
public long computeNextDeadLine()

createQuicNioSelector back to summary

createQuicNioSelector	back to summary
public static QuicSelector<? extends QuicEndpoint> createQuicNioSelector(QuicInstance quicInstance, String name) throws IOException Returns a new instance of `QuicNioSelector`. A `QuicNioSelector` is an implementation of `QuicSelector` based on non blocking Datagram Channels and using an underlying NIO Selector. The returned implementation can only be used with `QuicSelectableEndpoint` endpoints. Parameters quicInstance:QuicInstance the quic instance name:String the selector name Returns:QuicSelector<? extends QuicEndpoint> a new instance of `QuicNioSelector` Exceptions IOException: if an IOException occurs when creating the underlying `Selector`

public static QuicSelector<? extends QuicEndpoint> createQuicNioSelector(QuicInstance quicInstance, String name) throws IOException

Returns a new instance of QuicNioSelector.

A QuicNioSelector is an implementation of QuicSelector based on non blocking Datagram Channels and using an underlying NIO Selector.

The returned implementation can only be used with QuicSelectableEndpoint endpoints.

Parameters

quicInstance:QuicInstance: the quic instance
name:String: the selector name

Returns:QuicSelector<? extends QuicEndpoint>

a new instance of QuicNioSelector

Exceptions

IOException:: if an IOException occurs when creating the underlying Selector

createQuicVirtualThreadPoller back to summary

createQuicVirtualThreadPoller	back to summary
public static QuicSelector<? extends QuicEndpoint> createQuicVirtualThreadPoller(QuicInstance quicInstance, String name) Returns a new instance of `QuicVirtualThreadPoller`. A `QuicVirtualThreadPoller` is an implementation of `QuicSelector` based on blocking Datagram Channels and using Virtual Threads to poll the datagram channels. The returned implementation can only be used with `QuicVirtualThreadedEndpoint` endpoints. Parameters quicInstance:QuicInstance the quic instance name:String the selector name Returns:QuicSelector<? extends QuicEndpoint> a new instance of `QuicVirtualThreadPoller`

public static QuicSelector<? extends QuicEndpoint> createQuicVirtualThreadPoller(QuicInstance quicInstance, String name)

Returns a new instance of QuicVirtualThreadPoller. A QuicVirtualThreadPoller is an implementation of QuicSelector based on blocking Datagram Channels and using Virtual Threads to poll the datagram channels.

The returned implementation can only be used with QuicVirtualThreadedEndpoint endpoints.

Parameters

quicInstance:QuicInstance: the quic instance
name:String: the selector name

Returns:QuicSelector<? extends QuicEndpoint>

a new instance of QuicVirtualThreadPoller

done	back to summary
pack-priv boolean done()

isSelectorThread	back to summary
public static boolean isSelectorThread()

name	back to summary
public String name()

register	back to summary
public void register(T endpoint) throws ClosedChannelException

run	back to summary
public final void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation. Annotations @Override

run

back to summary

public final void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

runSelector	back to summary
pack-priv abstract void runSelector()

shutdown back to summary

shutdown	back to summary
public void shutdown() Shuts down the `QuicSelector` by invoking `Selector#close()`. This method doesn't wait for the selector thread to terminate. See Also `awaitTermination(long, TimeUnit)`

public void shutdown()

Shuts down the QuicSelector by invoking Selector#close(). This method doesn't wait for the selector thread to terminate.

See Also: awaitTermination(long, TimeUnit)

start	back to summary
public void start()

timer	back to summary
public QuicTimerQueue timer()

toString back to summary

toString	back to summary
public String toString() Overrides java.lang.Object.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Satisfying this method's contract implies a non-`null` result must be returned. Annotations @Override

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object. Satisfying this method's contract implies a non-null result must be returned.

Annotations

@Override

wakeup	back to summary
public void wakeup()

jdk.internal.net.http.quic back to summary

pack-priv final Class QuicSelector.QuicNioSelector

Class Inheritance

extends QuicSelector<QuicEndpoint.QuicSelectableEndpoint>

java.lang.Object
jdk.internal.net.http.quic.QuicSelector
jdk.internal.net.http.quic.QuicSelector.QuicNioSelector

A QuicSelector implementation based on non-blocking Datagram Channels and using a NIO Selector. This implementation is tied to QuicSelectableEndpoint instances.

Field Summary

Modifier and Type	Field and Description
pack-priv final Selector	selector

Inherited from jdk.internal.net.http.quic.QuicSelector:: debug IDLE_PERIOD_MS

Constructor Summary

Access	Constructor and Description
private	QuicNioSelector(QuicInstance instance, Selector selector, String name)

Method Summary

Modifier and Type	Method and Description
pack-priv boolean	abort(SelectionKey key, Throwable error)
public void	abort(Throwable error) Overrides jdk.internal.net.http.quic.QuicSelector.abort.
public void	register(QuicEndpoint.QuicSelectableEndpoint endpoint) Overrides jdk.internal.net.http.quic.QuicSelector.register.
pack-priv void	runSelector() Implements abstract jdk.internal.net.http.quic.QuicSelector.runSelector.
public void	shutdown() Overrides jdk.internal.net.http.quic.QuicSelector.shutdown. Shuts down the `QuicSelector` by marking the selector done, and waking up the selector thread.
public void	wakeup() Overrides jdk.internal.net.http.quic.QuicSelector.wakeup.

Inherited from jdk.internal.net.http.quic.QuicSelector:: awaitTermination close computeNextDeadLine createQuicNioSelector createQuicVirtualThreadPoller done isSelectorThread name run start timer toString

Field Detail

selector	back to summary
pack-priv final Selector selector

Constructor Detail

QuicNioSelector	back to summary
private QuicNioSelector(QuicInstance instance, Selector selector, String name)

Method Detail

abort	back to summary
pack-priv boolean abort(SelectionKey key, Throwable error)

abort	back to summary
public void abort(Throwable error) Overrides jdk.internal.net.http.quic.QuicSelector.abort. Annotations @Override

abort

back to summary

public void abort(Throwable error)

Overrides jdk.internal.net.http.quic.QuicSelector.abort.

Annotations

@Override

register	back to summary
public void register(QuicEndpoint.QuicSelectableEndpoint endpoint) throws ClosedChannelException Overrides jdk.internal.net.http.quic.QuicSelector.register.

runSelector	back to summary
pack-priv void runSelector() Implements abstract jdk.internal.net.http.quic.QuicSelector.runSelector. Annotations @Override

runSelector

back to summary

pack-priv void runSelector()

Implements abstract jdk.internal.net.http.quic.QuicSelector.runSelector.

Annotations

@Override

shutdown back to summary

shutdown	back to summary
public void shutdown() Overrides jdk.internal.net.http.quic.QuicSelector.shutdown. Shuts down the `QuicSelector` by marking the selector done, and waking up the selector thread. Upon waking up, the selector thread will invoke `Selector#close()`. This method doesn't wait for the selector thread to terminate. See Also `awaitTermination(long, TimeUnit)`

public void shutdown()

Overrides jdk.internal.net.http.quic.QuicSelector.shutdown.

Shuts down the QuicSelector by marking the selector done, and waking up the selector thread. Upon waking up, the selector thread will invoke Selector#close(). This method doesn't wait for the selector thread to terminate.

See Also: awaitTermination(long, TimeUnit)

wakeup	back to summary
public void wakeup() Overrides jdk.internal.net.http.quic.QuicSelector.wakeup.

jdk.internal.net.http.quic back to summary

private final Record QuicSelector.QuicSelectorThread

Class Inheritance

extends Record

java.lang.Object
java.lang.Record
jdk.internal.net.http.quic.QuicSelector.QuicSelectorThread

Record Components

thread:Thread

Field Summary

Modifier and Type	Field and Description
private final Thread	thread Record Component accessed by thread().

Constructor Summary

Access	Constructor and Description
private	QuicSelectorThread(Thread thread)

Method Summary

Modifier and Type	Method and Description
public final boolean	equals(Object o) Implements abstract java.lang.Record.equals. Indicates whether some other object is "equal to" this one.
public final int	hashCode() Implements abstract java.lang.Record.hashCode. Returns a hash code value for the record.
pack-priv void	join(long millis)
pack-priv static QuicSelector.QuicSelectorThread	of(Utils.UseVTForSelector config, QuicSelector<?> selector)
pack-priv static QuicSelector.QuicSelectorThread	ofPlatform(QuicSelector<?> selector)
pack-priv static QuicSelector.QuicSelectorThread	ofVirtual(QuicSelector<?> selector)
pack-priv void	start()
public Thread	thread() Record Component getter of thread.
public final String	toString() Implements abstract java.lang.Record.toString. Returns a string representation of the record.

Field Detail

thread	back to summary
private final Thread thread Record Component accessed by thread().

Constructor Detail

QuicSelectorThread	back to summary
private QuicSelectorThread(Thread thread)

Method Detail

equals back to summary

equals	back to summary
public final boolean equals(Object o) Implements abstract java.lang.Record.equals. Doc from java.lang.Record.equals. Indicates whether some other object is "equal to" this one. In addition to the general contract of `Object.equals`, record classes must further obey the invariant that when a record instance is "copied" by passing the result of the record component accessor methods to the canonical constructor, as follows: R copy = new R(r.c1(), r.c2(), ..., r.cn()); then it must be the case that `r.equals(copy)`.

public final boolean equals(Object o)

Implements abstract java.lang.Record.equals.

Doc from java.lang.Record.equals.

Indicates whether some other object is "equal to" this one. In addition to the general contract of Object.equals, record classes must further obey the invariant that when a record instance is "copied" by passing the result of the record component accessor methods to the canonical constructor, as follows:

    R copy = new R(r.c1(), r.c2(), ..., r.cn());

then it must be the case that r.equals(copy).

hashCode back to summary

hashCode	back to summary
public final int hashCode() Implements abstract java.lang.Record.hashCode. Doc from java.lang.Record.hashCode. Returns a hash code value for the record. Obeys the general contract of `Object.hashCode`. For records, hashing behavior is constrained by the refined contract of `Record.equals`, so that any two records created from the same components must have the same hash code.

public final int hashCode()

Implements abstract java.lang.Record.hashCode.

Doc from java.lang.Record.hashCode.

Returns a hash code value for the record. Obeys the general contract of Object.hashCode. For records, hashing behavior is constrained by the refined contract of Record.equals, so that any two records created from the same components must have the same hash code.

join	back to summary
pack-priv void join(long millis) throws InterruptedException

of	back to summary
pack-priv static QuicSelector.QuicSelectorThread of(Utils.UseVTForSelector config, QuicSelector<?> selector)

ofPlatform	back to summary
pack-priv static QuicSelector.QuicSelectorThread ofPlatform(QuicSelector<?> selector)

ofVirtual	back to summary
pack-priv static QuicSelector.QuicSelectorThread ofVirtual(QuicSelector<?> selector)

start	back to summary
pack-priv void start()

thread	back to summary
public Thread thread() Record Component getter of thread.

toString back to summary

public final String toString()

Implements abstract java.lang.Record.toString.

Doc from java.lang.Record.toString.

Returns a string representation of the record. In accordance with the general contract of Object#toString(), the toString method returns a string that "textually represents" this record. The result should be a concise but informative representation that is easy for a person to read.

In addition to this general contract, record classes must further participate in the invariant that any two records which are equal must produce equal strings. This invariant is necessarily relaxed in the rare case where corresponding equal component values might fail to produce equal strings for themselves.

jdk.internal.net.http.quic back to summary

pack-priv final Class QuicSelector.QuicVirtualThreadPoller

Class Inheritance

extends QuicSelector<QuicEndpoint.QuicVirtualThreadedEndpoint>

java.lang.Object
jdk.internal.net.http.quic.QuicSelector
jdk.internal.net.http.quic.QuicSelector.QuicVirtualThreadPoller

A QuicSelector implementation based on blocking Datagram Channels and using a Virtual Threads to poll the channels. This implementation is tied to QuicVirtualThreadedEndpoint instances.

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	QuicSelector.QuicVirtualThreadPoller.EndpointTask

Field Summary

Modifier and Type	Field and Description
private final ConcurrentLinkedQueue<QuicSelector.QuicVirtualThreadPoller.EndpointTask>	endpoints
private final ReentrantLock	stateLock
pack-priv static final boolean	usePlatformThreads
private final ExecutorService	virtualThreadService
private final Object	waiter
private volatile long	wakeups

Inherited from jdk.internal.net.http.quic.QuicSelector:: debug IDLE_PERIOD_MS

Constructor Summary

Access	Constructor and Description
private	QuicVirtualThreadPoller(QuicInstance instance, String name)

Method Summary

Modifier and Type	Method and Description
pack-priv boolean	abort(QuicSelector.QuicVirtualThreadPoller.EndpointTask task, Throwable error)
public void	abort(Throwable t) Overrides jdk.internal.net.http.quic.QuicSelector.abort.
pack-priv boolean	close(QuicSelector.QuicVirtualThreadPoller.EndpointTask task)
pack-priv void	markDone()
pack-priv ExecutorService	readLoopExecutor()
public void	register(QuicEndpoint.QuicVirtualThreadedEndpoint endpoint) Overrides jdk.internal.net.http.quic.QuicSelector.register.
pack-priv void	runSelector() Implements abstract jdk.internal.net.http.quic.QuicSelector.runSelector.
public void	shutdown() Overrides jdk.internal.net.http.quic.QuicSelector.shutdown. Shuts down the `QuicSelector` by invoking `Selector#close()`.
public Future<?>	startReading(QuicEndpoint.QuicVirtualThreadedEndpoint endpoint)
public void	wakeup() Overrides jdk.internal.net.http.quic.QuicSelector.wakeup.

Inherited from jdk.internal.net.http.quic.QuicSelector:: awaitTermination close computeNextDeadLine createQuicNioSelector createQuicVirtualThreadPoller done isSelectorThread name run start timer toString

Field Detail

endpoints	back to summary
private final ConcurrentLinkedQueue<QuicSelector.QuicVirtualThreadPoller.EndpointTask> endpoints

stateLock	back to summary
private final ReentrantLock stateLock

usePlatformThreads	back to summary
pack-priv static final boolean usePlatformThreads

virtualThreadService	back to summary
private final ExecutorService virtualThreadService

waiter	back to summary
private final Object waiter

wakeups	back to summary
private volatile long wakeups

Constructor Detail

QuicVirtualThreadPoller	back to summary
private QuicVirtualThreadPoller(QuicInstance instance, String name)

Method Detail

abort	back to summary
pack-priv boolean abort(QuicSelector.QuicVirtualThreadPoller.EndpointTask task, Throwable error)

abort

back to summary

public void abort(Throwable t)

Overrides jdk.internal.net.http.quic.QuicSelector.abort.

Annotations

@Override

close	back to summary
pack-priv boolean close(QuicSelector.QuicVirtualThreadPoller.EndpointTask task)

markDone	back to summary
pack-priv void markDone()

readLoopExecutor	back to summary
pack-priv ExecutorService readLoopExecutor()

back to summary

public void register(QuicEndpoint.QuicVirtualThreadedEndpoint endpoint) throws ClosedChannelException

Overrides jdk.internal.net.http.quic.QuicSelector.register.

Annotations

@Override

runSelector

back to summary

pack-priv void runSelector()

Implements abstract jdk.internal.net.http.quic.QuicSelector.runSelector.

Annotations

@Override

shutdown back to summary

public void shutdown()

Overrides jdk.internal.net.http.quic.QuicSelector.shutdown.

Doc from jdk.internal.net.http.quic.QuicSelector.shutdown.

Shuts down the QuicSelector by invoking Selector#close(). This method doesn't wait for the selector thread to terminate.

Annotations

@Override

startReading	back to summary
public Future<?> startReading(QuicEndpoint.QuicVirtualThreadedEndpoint endpoint)

wakeup

back to summary

public void wakeup()

Overrides jdk.internal.net.http.quic.QuicSelector.wakeup.

Annotations

@Override

jdk.internal.net.http.quic back to summary

pack-priv final Class QuicSelector.QuicVirtualThreadPoller.EndpointTask

Class Inheritance

extends Object
implements Runnable

java.lang.Object
jdk.internal.net.http.quic.QuicSelector.QuicVirtualThreadPoller.EndpointTask

All Implemented Interfaces

java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
pack-priv final QuicEndpoint.QuicVirtualThreadedEndpoint	endpoint
pack-priv final ConcurrentLinkedQueue<QuicSelector.QuicVirtualThreadPoller.EndpointTask>	endpoints

Constructor Summary

Access	Constructor and Description
pack-priv	EndpointTask(QuicEndpoint.QuicVirtualThreadedEndpoint endpoint, ConcurrentLinkedQueue<QuicSelector.QuicVirtualThreadPoller.EndpointTask> endpoints)

Method Summary

Modifier and Type	Method and Description
public void	run() Implements java.lang.Runnable.run. Runs this operation.

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

Field Detail

endpoint	back to summary
pack-priv final QuicEndpoint.QuicVirtualThreadedEndpoint endpoint

endpoints	back to summary
pack-priv final ConcurrentLinkedQueue<QuicSelector.QuicVirtualThreadPoller.EndpointTask> endpoints

Constructor Detail

EndpointTask	back to summary
pack-priv EndpointTask(QuicEndpoint.QuicVirtualThreadedEndpoint endpoint, ConcurrentLinkedQueue<QuicSelector.QuicVirtualThreadPoller.EndpointTask> endpoints)

Method Detail

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

public abstract sealed Class QuicSelector<T extends QuicEndpoint>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class QuicSelector.QuicNioSelector

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Record QuicSelector.QuicSelectorThread

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class QuicSelector.QuicVirtualThreadPoller

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class QuicSelector.QuicVirtualThreadPoller.EndpointTask

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail