Modifier and Type	Class and Description
private static enum	HTTP3Session.CloseState
private class	HTTP3Session.StreamTimeouts

Modifier and Type	Field and Description
private HTTP3Session.CloseState	closeState
private GoAwayFrame	goAwayRecv
private GoAwayFrame	goAwaySent
private final AtomicLong	lastStreamId
private final Session.Listener	listener
private final AutoLock	lock
private static final Logger	LOG Hides org.eclipse.jetty.util.component.ContainerLifeCycle.LOG.
private final ProtocolSession	session
private CompletableFuture<Void>	shutdown
private final AtomicInteger	streamCount
private long	streamIdleTimeout
private final Map<Long, HTTP3Stream>	streams
private final HTTP3Session.StreamTimeouts	streamTimeouts
private Runnable	zeroStreamsAction

Access	Constructor and Description
public	HTTP3Session(ProtocolSession session, Session.Listener listener)

Method Summary

Modifier and Type	Method and Description
protected HTTP3Stream	createStream(QuicStreamEndPoint endPoint, Consumer<Throwable> fail)
public void	dump(Appendable out, String indent) Overrides org.eclipse.jetty.util.component.ContainerLifeCycle.dump. Implements org.eclipse.jetty.util.component.Dumpable.dump. Dump this object (and children) into an Appendable using the provided indent after any new lines.
private void	failStreams(Predicate<HTTP3Stream> predicate, long error, String reason, boolean close, Throwable failure)
public long	getIdleTimeout()
public Session.Listener	getListener()
public SocketAddress	getLocalSocketAddress() Overrides default org.eclipse.jetty.http3.api.Session.getLocalSocketAddress. Get the local socket address this session is bound to.
public int	getMaxLocalStreams()
protected HTTP3Stream	getOrCreateStream(QuicStreamEndPoint endPoint)
public ProtocolSession	getProtocolSession()
public SocketAddress	getRemoteSocketAddress() Overrides default org.eclipse.jetty.http3.api.Session.getRemoteSocketAddress. Get the remote socket address this session is connected to.
protected HTTP3Stream	getStream(long streamId)
public long	getStreamIdleTimeout()
public Collection<Stream>	getStreams() Overrides default org.eclipse.jetty.http3.api.Session.getStreams.
public CompletableFuture<Void>	goAway(boolean graceful) Overrides default org.eclipse.jetty.http3.api.Session.goAway. Initiates the shutdown of this session by sending a GOAWAY frame to the other peer.
private CompletableFuture<Void>	goAway(GoAwayFrame frame)
public void	inwardClose(long the close error error, String the close reason reason) Called when a an external event wants to initiate the close of this session locally, for example a close at the network level (due to e.g. stopping a component) or a timeout.
public boolean	isClosed()
protected GoAwayFrame	newGoAwayFrame(boolean graceful)
private HTTP3Stream	newHTTP3Stream(QuicStreamEndPoint endPoint, Consumer<Throwable> fail, boolean local)
protected abstract HTTP3Stream	newHTTP3Stream(QuicStreamEndPoint endPoint, boolean local)
private void	notifyDisconnect(long error, String reason)
private void	notifyFailure(long error, String reason, Throwable failure)
private void	notifyGoAway(GoAwayFrame frame)
private boolean	notifyIdleTimeout()
private Map<Long, Long>	notifyPreface()
private void	notifySettings(SettingsFrame frame)
public void	onClose(long the close error error, String the close reason reason) Called when the local peer receives a close initiated by the remote peer.
public void	onData(long streamId, DataFrame frame) Overrides default org.eclipse.jetty.http3.parser.ParserListener.onData.
public void	onGoAway(GoAwayFrame frame) Overrides default org.eclipse.jetty.http3.parser.ParserListener.onGoAway.
public void	onHeaders(long streamId, HeadersFrame frame, boolean wasBlocked) Overrides default org.eclipse.jetty.http3.parser.ParserListener.onHeaders.
public boolean	onIdleTimeout()
public void	onOpen()
public Map<Long, Long>	onPreface()
public void	onSessionFailure(long error, String reason, Throwable failure) Overrides default org.eclipse.jetty.http3.parser.ParserListener.onSessionFailure.
public void	onSettings(SettingsFrame frame) Overrides default org.eclipse.jetty.http3.parser.ParserListener.onSettings.
public void	onStreamFailure(long streamId, long error, Throwable failure) Overrides default org.eclipse.jetty.http3.parser.ParserListener.onStreamFailure.
private void	outwardClose(long the close error error, String the close reason reason) Propagates a close outwards, i.e. towards the network.
private void	outwardDisconnect(long the close error error, String the close reason. reason) Calls `outwardClose(long, String)`, then notifies `Session.Listener#onDisconnect(Session, long, String)`.
public void	removeStream(HTTP3Stream stream, Throwable failure)
pack-priv void	scheduleIdleTimeout(HTTP3Stream stream)
public void	setStreamIdleTimeout(long streamIdleTimeout)
public CompletableFuture<Void>	shutdown()
private void	terminate() Terminates this session at the HTTP/3 level, and possibly notifies the shutdown callback.
private void	terminateAndDisconnect(long error, String reason)
public String	toString() Overrides org.eclipse.jetty.util.component.AbstractLifeCycle.toString. Returns a string representation of the object.
private void	tryRunZeroStreamsAction()
private void	updateLastStreamId(long id)
public abstract void	writeControlFrame(Frame frame, Callback callback)
public abstract void	writeMessageFrame(long streamId, Frame frame, Callback callback)

Field Detail

closeState	back to summary
private HTTP3Session.CloseState closeState

goAwayRecv	back to summary
private GoAwayFrame goAwayRecv

goAwaySent	back to summary
private GoAwayFrame goAwaySent

lastStreamId	back to summary
private final AtomicLong lastStreamId

listener	back to summary
private final Session.Listener listener

lock	back to summary
private final AutoLock lock

LOG	back to summary
private static final Logger LOG Hides org.eclipse.jetty.util.component.ContainerLifeCycle.LOG.

session	back to summary
private final ProtocolSession session

shutdown	back to summary
private CompletableFuture<Void> shutdown

streamCount	back to summary
private final AtomicInteger streamCount

streamIdleTimeout	back to summary
private long streamIdleTimeout

streams	back to summary
private final Map<Long, HTTP3Stream> streams

streamTimeouts	back to summary
private final HTTP3Session.StreamTimeouts streamTimeouts

zeroStreamsAction	back to summary
private Runnable zeroStreamsAction

Constructor Detail

HTTP3Session	back to summary
public HTTP3Session(ProtocolSession session, Session.Listener listener)

Method Detail

createStream	back to summary
protected HTTP3Stream createStream(QuicStreamEndPoint endPoint, Consumer<Throwable> fail)

dump	back to summary
public void dump(Appendable out, String indent) throws IOException Overrides org.eclipse.jetty.util.component.ContainerLifeCycle.dump. Implements org.eclipse.jetty.util.component.Dumpable.dump. Doc from org.eclipse.jetty.util.component.Dumpable.dump. Dump this object (and children) into an Appendable using the provided indent after any new lines. The indent should not be applied to the first object dumped. Annotations @Override Exceptions IOException: if unable to write to Appendable

dump

back to summary

public void dump(Appendable out, String indent) throws IOException

Overrides org.eclipse.jetty.util.component.ContainerLifeCycle.dump.

Implements org.eclipse.jetty.util.component.Dumpable.dump.

Doc from org.eclipse.jetty.util.component.Dumpable.dump.

Dump this object (and children) into an Appendable using the provided indent after any new lines. The indent should not be applied to the first object dumped.

Annotations

@Override

Exceptions

IOException:: if unable to write to Appendable

failStreams	back to summary
private void failStreams(Predicate<HTTP3Stream> predicate, long error, String reason, boolean close, Throwable failure)

getIdleTimeout	back to summary
public long getIdleTimeout()

getListener	back to summary
public Session.Listener getListener()

getLocalSocketAddress	back to summary
public SocketAddress getLocalSocketAddress() Overrides default org.eclipse.jetty.http3.api.Session.getLocalSocketAddress. Doc from org.eclipse.jetty.http3.api.Session.getLocalSocketAddress. Get the local socket address this session is bound to. Annotations @Override

getLocalSocketAddress

back to summary

public SocketAddress getLocalSocketAddress()

Overrides default org.eclipse.jetty.http3.api.Session.getLocalSocketAddress.

Doc from org.eclipse.jetty.http3.api.Session.getLocalSocketAddress.

Get the local socket address this session is bound to.

Annotations

@Override

getMaxLocalStreams	back to summary
public int getMaxLocalStreams()

getOrCreateStream	back to summary
protected HTTP3Stream getOrCreateStream(QuicStreamEndPoint endPoint)

getProtocolSession	back to summary
public ProtocolSession getProtocolSession()

getRemoteSocketAddress	back to summary
public SocketAddress getRemoteSocketAddress() Overrides default org.eclipse.jetty.http3.api.Session.getRemoteSocketAddress. Doc from org.eclipse.jetty.http3.api.Session.getRemoteSocketAddress. Get the remote socket address this session is connected to. Annotations @Override

getRemoteSocketAddress

back to summary

public SocketAddress getRemoteSocketAddress()

Overrides default org.eclipse.jetty.http3.api.Session.getRemoteSocketAddress.

Doc from org.eclipse.jetty.http3.api.Session.getRemoteSocketAddress.

Get the remote socket address this session is connected to.

Annotations

@Override

getStream	back to summary
protected HTTP3Stream getStream(long streamId)

getStreamIdleTimeout	back to summary
public long getStreamIdleTimeout()

getStreams	back to summary
public Collection<Stream> getStreams() Overrides default org.eclipse.jetty.http3.api.Session.getStreams. Annotations @Override

getStreams

back to summary

public Collection<Stream> getStreams()

Overrides default org.eclipse.jetty.http3.api.Session.getStreams.

Annotations

@Override

goAway	back to summary
public CompletableFuture<Void> goAway(boolean graceful) Overrides default org.eclipse.jetty.http3.api.Session.goAway. Doc from org.eclipse.jetty.http3.api.Session.goAway. Initiates the shutdown of this session by sending a GOAWAY frame to the other peer. Annotations @Override

goAway

back to summary

public CompletableFuture<Void> goAway(boolean graceful)

Overrides default org.eclipse.jetty.http3.api.Session.goAway.

Doc from org.eclipse.jetty.http3.api.Session.goAway.

Initiates the shutdown of this session by sending a GOAWAY frame to the other peer.

Annotations

@Override

goAway	back to summary
private CompletableFuture<Void> goAway(GoAwayFrame frame)

inwardClose back to summary

inwardClose	back to summary
public void inwardClose(long error, String reason) Called when a an external event wants to initiate the close of this session locally, for example a close at the network level (due to e.g. stopping a component) or a timeout. The correspondent passive event, where it's the remote peer that initiates the close, is delivered via `onClose(long, String)`. Parameters error:long the close error reason:String the close reason See Also `onClose(long, String)`

public void inwardClose(long error, String reason)

Called when a an external event wants to initiate the close of this session locally, for example a close at the network level (due to e.g. stopping a component) or a timeout.

The correspondent passive event, where it's the remote peer that initiates the close, is delivered via onClose(long, String).

Parameters

error:long: the close error
reason:String: the close reason

See Also

onClose(long, String)

isClosed	back to summary
public boolean isClosed()

newGoAwayFrame	back to summary
protected GoAwayFrame newGoAwayFrame(boolean graceful)

newHTTP3Stream	back to summary
private HTTP3Stream newHTTP3Stream(QuicStreamEndPoint endPoint, Consumer<Throwable> fail, boolean local)

newHTTP3Stream	back to summary
protected abstract HTTP3Stream newHTTP3Stream(QuicStreamEndPoint endPoint, boolean local)

notifyDisconnect	back to summary
private void notifyDisconnect(long error, String reason)

notifyFailure	back to summary
private void notifyFailure(long error, String reason, Throwable failure)

notifyGoAway	back to summary
private void notifyGoAway(GoAwayFrame frame)

notifyIdleTimeout	back to summary
private boolean notifyIdleTimeout()

notifyPreface	back to summary
private Map<Long, Long> notifyPreface()

notifySettings	back to summary
private void notifySettings(SettingsFrame frame)

onClose back to summary

onClose	back to summary
public void onClose(long error, String reason) Called when the local peer receives a close initiated by the remote peer. The correspondent active event, where it's the local peer that initiates the close, it's delivered via `inwardClose(long, String)`. Parameters error:long the close error reason:String the close reason

public void onClose(long error, String reason)

Called when the local peer receives a close initiated by the remote peer.

The correspondent active event, where it's the local peer that initiates the close, it's delivered via inwardClose(long, String).

Parameters

error:long: the close error
reason:String: the close reason

onData	back to summary
public void onData(long streamId, DataFrame frame) Overrides default org.eclipse.jetty.http3.parser.ParserListener.onData. Annotations @Override

onData

back to summary

public void onData(long streamId, DataFrame frame)

Overrides default org.eclipse.jetty.http3.parser.ParserListener.onData.

Annotations

@Override

onGoAway	back to summary
public void onGoAway(GoAwayFrame frame) Overrides default org.eclipse.jetty.http3.parser.ParserListener.onGoAway. Annotations @Override

onGoAway

back to summary

public void onGoAway(GoAwayFrame frame)

Overrides default org.eclipse.jetty.http3.parser.ParserListener.onGoAway.

Annotations

@Override

onHeaders	back to summary
public void onHeaders(long streamId, HeadersFrame frame, boolean wasBlocked) Overrides default org.eclipse.jetty.http3.parser.ParserListener.onHeaders. Annotations @Override

onHeaders

back to summary

public void onHeaders(long streamId, HeadersFrame frame, boolean wasBlocked)

Overrides default org.eclipse.jetty.http3.parser.ParserListener.onHeaders.

Annotations

@Override

onIdleTimeout	back to summary
public boolean onIdleTimeout()

onOpen	back to summary
public void onOpen()

onPreface	back to summary
public Map<Long, Long> onPreface()

onSessionFailure

back to summary

public void onSessionFailure(long error, String reason, Throwable failure)

Overrides default org.eclipse.jetty.http3.parser.ParserListener.onSessionFailure.

Annotations

@Override

onSettings

back to summary

public void onSettings(SettingsFrame frame)

Overrides default org.eclipse.jetty.http3.parser.ParserListener.onSettings.

Annotations

@Override

onStreamFailure

back to summary

public void onStreamFailure(long streamId, long error, Throwable failure)

Overrides default org.eclipse.jetty.http3.parser.ParserListener.onStreamFailure.

Annotations

@Override

outwardClose back to summary

private void outwardClose(long error, String reason)

Propagates a close outwards, i.e. towards the network.

This method does not notify Session.Listener#onDisconnect(Session, long, String) so calling outwardDisconnect(long, String) is preferred.

Parameters

error:long: the close error
reason:String: the close reason

outwardDisconnect back to summary

private void outwardDisconnect(long error, String reason)

Calls outwardClose(long, String), then notifies Session.Listener#onDisconnect(Session, long, String).

Parameters

error:long: the close error
reason:String: the close reason.

See Also

outwardClose(long, String)

removeStream	back to summary
public void removeStream(HTTP3Stream stream, Throwable failure)

scheduleIdleTimeout	back to summary
pack-priv void scheduleIdleTimeout(HTTP3Stream stream)

setStreamIdleTimeout	back to summary
public void setStreamIdleTimeout(long streamIdleTimeout)

shutdown	back to summary
public CompletableFuture<Void> shutdown()

terminate back to summary

private void terminate()

Terminates this session at the HTTP/3 level, and possibly notifies the shutdown callback. Termination at the QUIC level may still be in progress.

See Also: onClose(long, String), inwardClose(long, String)

terminateAndDisconnect	back to summary
private void terminateAndDisconnect(long error, String reason)

toString back to summary

public String toString()

Overrides org.eclipse.jetty.util.component.AbstractLifeCycle.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

tryRunZeroStreamsAction	back to summary
private void tryRunZeroStreamsAction()

updateLastStreamId	back to summary
private void updateLastStreamId(long id)

writeControlFrame	back to summary
public abstract void writeControlFrame(Frame frame, Callback callback)

writeMessageFrame	back to summary
public abstract void writeMessageFrame(long streamId, Frame frame, Callback callback)

org.eclipse.jetty.http3 back to summary

private final Enum HTTP3Session.CloseState

Class Inheritance

extends Enum<HTTP3Session.CloseState>

java.lang.Object
java.lang.Enum
org.eclipse.jetty.http3.HTTP3Session.CloseState

Field Summary

Modifier and Type	Field and Description
public static final HTTP3Session.CloseState	CLOSED
public static final HTTP3Session.CloseState	CLOSING
public static final HTTP3Session.CloseState	LOCALLY_CLOSED
public static final HTTP3Session.CloseState	NOT_CLOSED
public static final HTTP3Session.CloseState	REMOTELY_CLOSED

Constructor Summary

Access	Constructor and Description
private	CloseState()

Method Summary

Modifier and Type	Method and Description
public static HTTP3Session.CloseState	valueOf(String name)
public static HTTP3Session.CloseState[]	values()

Inherited from java.lang.Enum:: clone compareTo describeConstable equals finalize getDeclaringClass hashCode name ordinal toString valueOf

Field Detail

CLOSED	back to summary
public static final HTTP3Session.CloseState CLOSED

CLOSING	back to summary
public static final HTTP3Session.CloseState CLOSING

LOCALLY_CLOSED	back to summary
public static final HTTP3Session.CloseState LOCALLY_CLOSED

NOT_CLOSED	back to summary
public static final HTTP3Session.CloseState NOT_CLOSED

REMOTELY_CLOSED	back to summary
public static final HTTP3Session.CloseState REMOTELY_CLOSED

Constructor Detail

CloseState	back to summary
private CloseState()

Method Detail

valueOf	back to summary
public static HTTP3Session.CloseState valueOf(String name)

values	back to summary
public static HTTP3Session.CloseState[] values()

org.eclipse.jetty.http3 back to summary

private Class HTTP3Session.StreamTimeouts

Class Inheritance

extends CyclicTimeouts<HTTP3Stream>

java.lang.Object
org.eclipse.jetty.io.CyclicTimeouts
org.eclipse.jetty.http3.HTTP3Session.StreamTimeouts

Constructor Summary

Access	Constructor and Description
private	StreamTimeouts(Scheduler scheduler)

Method Summary

Modifier and Type	Method and Description
protected Iterator<HTTP3Stream>	iterator() Implements abstract org.eclipse.jetty.io.CyclicTimeouts.iterator.
protected boolean	onExpired(HTTP3Stream stream) Implements abstract org.eclipse.jetty.io.CyclicTimeouts.onExpired. Invoked during the iteration when the given entity is expired.

Inherited from org.eclipse.jetty.io.CyclicTimeouts:: destroy schedule

Constructor Detail

StreamTimeouts	back to summary
private StreamTimeouts(Scheduler scheduler)

Method Detail

iterator

back to summary

protected Iterator<HTTP3Stream> iterator()

Implements abstract org.eclipse.jetty.io.CyclicTimeouts.iterator.

Annotations

@Override

onExpired back to summary

protected boolean onExpired(HTTP3Stream stream)

Implements abstract org.eclipse.jetty.io.CyclicTimeouts.onExpired.

Doc from org.eclipse.jetty.io.CyclicTimeouts.onExpired.

Invoked during the iteration when the given entity is expired.

This method may be invoked multiple times, and even concurrently, for the same expirable entity and therefore the expiration of the entity, if any, should be an idempotent action.

When false is returned, the implementation should adjust the Expirable expiration, so that a call to Expirable#getExpireNanoTime() after this method has returned yields a new expiration nanoTime.

Annotations

@Override

public abstract Class HTTP3Session

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Enum HTTP3Session.CloseState

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class HTTP3Session.StreamTimeouts

Constructor Summary

Method Summary

Constructor Detail

Method Detail