Modifier and Type	Class and Description
pack-priv class	IdleTimeoutManager.IdleTimeoutEvent
pack-priv class	IdleTimeoutManager.PingEvent
pack-priv class	IdleTimeoutManager.StreamDataBlockedEvent
pack-priv abstract class	IdleTimeoutManager.TimedEvent

Modifier and Type	Field and Description
private boolean	chosenForIdleTermination
private final QuicConnectionImpl	connection
private final Logger	debug
private final ReentrantLock	idleTerminationLock
private final AtomicLong	idleTimeoutDurationMs
private IdleTimeoutManager.IdleTimeoutEvent	idleTimeoutEvent
private volatile long	lastPacketActivityNanos
private long	lastUsageReservationNanos
private static final long	NO_IDLE_TIMEOUT
private IdleTimeoutManager.PingEvent	pingEvent
private final AtomicBoolean	shutdown
private final ReentrantLock	stateLock
private IdleTimeoutManager.StreamDataBlockedEvent	streamDataBlockedEvent
private final AtomicReference<Supplier<Boolean>>	trafficGenerationCheck

Access	Constructor and Description
pack-priv	IdleTimeoutManager(final QuicConnectionImpl connection)

Method Summary

Modifier and Type	Method and Description
pack-priv void	appLayerMaxIdle(final Duration maxIdle, final Supplier<Boolean> trafficGenerationCheck)
private void	checkUpdateIdleTimeout(final long newIdleTimeoutMillis)
private long	computeInactivityMillis()
private static void	disableTimedEvent(final QuicTimerQueue timer, final IdleTimeoutManager.TimedEvent te)
pack-priv Optional<Long>	Returns: the idle timeout in milliseconds or empty getIdleTimeout() Returns the idle timeout duration, in milliseconds, negotiated for the connection represented by this `IdleTimeoutManager`.
private void	idleTimedOut()
pack-priv void	localIdleTimeout(final long timeoutMillis)
pack-priv void	markActive()
pack-priv void	peerIdleTimeout(final long timeoutMillis)
private void	requireSuccessfulHandshake()
pack-priv void	shutdown()
pack-priv void	start() Starts the idle timeout management for the connection.
private void	startIdleTerminationTimer()
private void	startPingTimer()
private void	startStreamDataBlockedTimer()
private void	stopIdleTerminationTimer()
private void	stopPingTimer()
private void	stopStreamDataBlockedTimer()
private TimeLine	timeLine()
pack-priv boolean	Returns: true if the connection has been successfully reserved. false otherwise; in which case the connection must not be handed out from the pool. tryReserveForUse() Attempts to notify the idle connection management that this connection should be considered "in use".

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

Field Detail

chosenForIdleTermination	back to summary
private boolean chosenForIdleTermination

connection	back to summary
private final QuicConnectionImpl connection

debug	back to summary
private final Logger debug

idleTerminationLock	back to summary
private final ReentrantLock idleTerminationLock

idleTimeoutDurationMs	back to summary
private final AtomicLong idleTimeoutDurationMs

idleTimeoutEvent	back to summary
private IdleTimeoutManager.IdleTimeoutEvent idleTimeoutEvent

lastPacketActivityNanos	back to summary
private volatile long lastPacketActivityNanos

lastUsageReservationNanos	back to summary
private long lastUsageReservationNanos

NO_IDLE_TIMEOUT	back to summary
private static final long NO_IDLE_TIMEOUT

pingEvent	back to summary
private IdleTimeoutManager.PingEvent pingEvent

shutdown	back to summary
private final AtomicBoolean shutdown

stateLock	back to summary
private final ReentrantLock stateLock

streamDataBlockedEvent	back to summary
private IdleTimeoutManager.StreamDataBlockedEvent streamDataBlockedEvent

trafficGenerationCheck	back to summary
private final AtomicReference<Supplier<Boolean>> trafficGenerationCheck

Constructor Detail

IdleTimeoutManager	back to summary
pack-priv IdleTimeoutManager(final QuicConnectionImpl connection)

Method Detail

appLayerMaxIdle	back to summary
pack-priv void appLayerMaxIdle(final Duration maxIdle, final Supplier<Boolean> trafficGenerationCheck)

checkUpdateIdleTimeout	back to summary
private void checkUpdateIdleTimeout(final long newIdleTimeoutMillis)

computeInactivityMillis	back to summary
private long computeInactivityMillis()

disableTimedEvent	back to summary
private static void disableTimedEvent(final QuicTimerQueue timer, final IdleTimeoutManager.TimedEvent te)

getIdleTimeout back to summary

getIdleTimeout	back to summary
pack-priv Optional<Long> getIdleTimeout() Returns the idle timeout duration, in milliseconds, negotiated for the connection represented by this `IdleTimeoutManager`. The negotiated idle timeout of a connection is the minimum of the idle connection timeout that is advertised by the endpoint represented by this `IdleTimeoutManager` and the idle connection timeout advertised by the peer. If neither endpoints have advertised any idle connection timeout then this method returns an empty value. Returns:Optional<Long> the idle timeout in milliseconds or empty

pack-priv Optional<Long> getIdleTimeout()

Returns the idle timeout duration, in milliseconds, negotiated for the connection represented by this IdleTimeoutManager. The negotiated idle timeout of a connection is the minimum of the idle connection timeout that is advertised by the endpoint represented by this IdleTimeoutManager and the idle connection timeout advertised by the peer. If neither endpoints have advertised any idle connection timeout then this method returns an empty value.

Returns:Optional<Long>: the idle timeout in milliseconds or empty

idleTimedOut	back to summary
private void idleTimedOut()

localIdleTimeout	back to summary
pack-priv void localIdleTimeout(final long timeoutMillis)

markActive	back to summary
pack-priv void markActive()

peerIdleTimeout	back to summary
pack-priv void peerIdleTimeout(final long timeoutMillis)

requireSuccessfulHandshake	back to summary
private void requireSuccessfulHandshake()

shutdown	back to summary
pack-priv void shutdown()

start	back to summary
pack-priv void start() Starts the idle timeout management for the connection. This should be called after the handshake is complete for the connection. Exceptions IllegalStateException: if handshake hasn't yet completed or if the handshake has failed for the connection

start

back to summary

pack-priv void start()

Starts the idle timeout management for the connection. This should be called after the handshake is complete for the connection.

Exceptions

IllegalStateException:: if handshake hasn't yet completed or if the handshake has failed for the connection

startIdleTerminationTimer	back to summary
private void startIdleTerminationTimer()

startPingTimer	back to summary
private void startPingTimer()

startStreamDataBlockedTimer	back to summary
private void startStreamDataBlockedTimer()

stopIdleTerminationTimer	back to summary
private void stopIdleTerminationTimer()

stopPingTimer	back to summary
private void stopPingTimer()

stopStreamDataBlockedTimer	back to summary
private void stopStreamDataBlockedTimer()

timeLine	back to summary
private TimeLine timeLine()

tryReserveForUse	back to summary
pack-priv boolean tryReserveForUse() Attempts to notify the idle connection management that this connection should be considered "in use". This way the idle connection management doesn't close this connection during the time the connection is handed out from the pool and any new stream created on that connection. Returns:boolean true if the connection has been successfully reserved. false otherwise; in which case the connection must not be handed out from the pool.

tryReserveForUse

back to summary

pack-priv boolean tryReserveForUse()

Attempts to notify the idle connection management that this connection should be considered "in use". This way the idle connection management doesn't close this connection during the time the connection is handed out from the pool and any new stream created on that connection.

Returns:boolean: true if the connection has been successfully reserved. false otherwise; in which case the connection must not be handed out from the pool.

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

pack-priv final Class IdleTimeoutManager.IdleTimeoutEvent

Class Inheritance

extends TimedEvent

java.lang.Object
jdk.internal.net.http.quic.IdleTimeoutManager.TimedEvent
jdk.internal.net.http.quic.IdleTimeoutManager.IdleTimeoutEvent

Field Summary

Inherited from jdk.internal.net.http.quic.IdleTimeoutManager.TimedEvent:: deadline eventId nextDeadline

Constructor Summary

Access	Constructor and Description
private	IdleTimeoutEvent(final Deadline deadline)

Method Summary

Modifier and Type	Method and Description
public Deadline	handle() Implements abstract jdk.internal.net.http.quic.IdleTimeoutManager.TimedEvent.handle. Implements jdk.internal.net.http.quic.QuicTimedEvent.handle. Handles the triggered event.
private Deadline	maybePostponeDeadline(final long expectedIdleDurationMs)
private void	terminateNow()
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

Inherited from jdk.internal.net.http.quic.IdleTimeoutManager.TimedEvent:: deadline eventId refreshDeadline

Constructor Detail

IdleTimeoutEvent	back to summary
private IdleTimeoutEvent(final Deadline deadline)

Method Detail

handle back to summary

handle	back to summary
public Deadline handle() Implements abstract jdk.internal.net.http.quic.IdleTimeoutManager.TimedEvent.handle. Implements jdk.internal.net.http.quic.QuicTimedEvent.handle. Doc from jdk.internal.net.http.quic.QuicTimedEvent.handle. Handles the triggered event. Returns a new deadline, if the event needs to be rescheduled, or `Deadline.MAX` otherwise. Annotations @Override

public Deadline handle()

Implements abstract jdk.internal.net.http.quic.IdleTimeoutManager.TimedEvent.handle.

Implements jdk.internal.net.http.quic.QuicTimedEvent.handle.

Doc from jdk.internal.net.http.quic.QuicTimedEvent.handle.

Handles the triggered event. Returns a new deadline, if the event needs to be rescheduled, or Deadline.MAX otherwise.

Annotations

@Override

maybePostponeDeadline	back to summary
private Deadline maybePostponeDeadline(final long expectedIdleDurationMs)

terminateNow	back to summary
private void terminateNow()

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

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

pack-priv final Class IdleTimeoutManager.PingEvent

Class Inheritance

extends TimedEvent

java.lang.Object
jdk.internal.net.http.quic.IdleTimeoutManager.TimedEvent
jdk.internal.net.http.quic.IdleTimeoutManager.PingEvent

Field Summary

Modifier and Type	Field and Description
private final long	idleTimeoutNanos
private final long	pingFrequencyNanos

Inherited from jdk.internal.net.http.quic.IdleTimeoutManager.TimedEvent:: deadline eventId nextDeadline

Constructor Summary

Access	Constructor and Description
private	PingEvent(final Deadline deadline, final long pingFrequencyMillis)

Method Summary

Modifier and Type	Method and Description
public Deadline	handle() Implements abstract jdk.internal.net.http.quic.IdleTimeoutManager.TimedEvent.handle. Implements jdk.internal.net.http.quic.QuicTimedEvent.handle. Handles the triggered event.
private boolean	shouldInitiateAppLayerCheck()
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

Inherited from jdk.internal.net.http.quic.IdleTimeoutManager.TimedEvent:: deadline eventId refreshDeadline

Field Detail

idleTimeoutNanos	back to summary
private final long idleTimeoutNanos

pingFrequencyNanos	back to summary
private final long pingFrequencyNanos

Constructor Detail

PingEvent	back to summary
private PingEvent(final Deadline deadline, final long pingFrequencyMillis)

Method Detail

handle back to summary

public Deadline handle()

Implements abstract jdk.internal.net.http.quic.IdleTimeoutManager.TimedEvent.handle.

Implements jdk.internal.net.http.quic.QuicTimedEvent.handle.

Doc from jdk.internal.net.http.quic.QuicTimedEvent.handle.

Handles the triggered event. Returns a new deadline, if the event needs to be rescheduled, or Deadline.MAX otherwise.

Annotations

@Override

shouldInitiateAppLayerCheck	back to summary
private boolean shouldInitiateAppLayerCheck()

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

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

pack-priv final Class IdleTimeoutManager.StreamDataBlockedEvent

Class Inheritance

extends TimedEvent

java.lang.Object
jdk.internal.net.http.quic.IdleTimeoutManager.TimedEvent
jdk.internal.net.http.quic.IdleTimeoutManager.StreamDataBlockedEvent

Field Summary

Modifier and Type	Field and Description
private final long	timeoutMillis

Inherited from jdk.internal.net.http.quic.IdleTimeoutManager.TimedEvent:: deadline eventId nextDeadline

Constructor Summary

Access	Constructor and Description
private	StreamDataBlockedEvent(final Deadline deadline, final long timeoutMillis)

Method Summary

Modifier and Type	Method and Description
public Deadline	handle() Implements abstract jdk.internal.net.http.quic.IdleTimeoutManager.TimedEvent.handle. Implements jdk.internal.net.http.quic.QuicTimedEvent.handle. Handles the triggered event.
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

Inherited from jdk.internal.net.http.quic.IdleTimeoutManager.TimedEvent:: deadline eventId refreshDeadline

Field Detail

timeoutMillis	back to summary
private final long timeoutMillis

Constructor Detail

StreamDataBlockedEvent	back to summary
private StreamDataBlockedEvent(final Deadline deadline, final long timeoutMillis)

Method Detail

handle back to summary

public Deadline handle()

Implements abstract jdk.internal.net.http.quic.IdleTimeoutManager.TimedEvent.handle.

Implements jdk.internal.net.http.quic.QuicTimedEvent.handle.

Doc from jdk.internal.net.http.quic.QuicTimedEvent.handle.

Handles the triggered event. Returns a new deadline, if the event needs to be rescheduled, or Deadline.MAX otherwise.

Annotations

@Override

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

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

pack-priv abstract sealed Class IdleTimeoutManager.TimedEvent

Class Inheritance

extends Object
implements QuicTimedEvent
permits IdleTimeoutEvent, StreamDataBlockedEvent, PingEvent

java.lang.Object
jdk.internal.net.http.quic.IdleTimeoutManager.TimedEvent

All Implemented Interfaces

jdk.internal.net.http.quic.QuicTimedEvent

Known Direct Subclasses

jdk.internal.net.http.quic.IdleTimeoutManager.IdleTimeoutEvent, jdk.internal.net.http.quic.IdleTimeoutManager.StreamDataBlockedEvent, jdk.internal.net.http.quic.IdleTimeoutManager.PingEvent

Field Summary

Modifier and Type	Field and Description
protected volatile Deadline	deadline
protected final long	eventId
protected volatile Deadline	nextDeadline

Constructor Summary

Access	Constructor and Description
private	TimedEvent(final Deadline deadline)

Method Summary

Modifier and Type	Method and Description
public final Deadline	deadline() Implements jdk.internal.net.http.quic.QuicTimedEvent.deadline. Returns the deadline at which the event should be triggered, or `Deadline#MAX` if the event does not need to be scheduled.
public final long	eventId() Implements jdk.internal.net.http.quic.QuicTimedEvent.eventId. An event id, obtained at construction time from `QuicTimerQueue#newEventId()`.
public abstract Deadline	handle() Redeclares jdk.internal.net.http.quic.QuicTimedEvent.handle. Handles the triggered event.
public final Deadline	refreshDeadline() Implements jdk.internal.net.http.quic.QuicTimedEvent.refreshDeadline. Called to cause an event to refresh its deadline.