Package org.eclipse.jetty.quic.common

Class QuicSession

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.component.ContainerLifeCycle

org.eclipse.jetty.quic.common.QuicSession

All Implemented Interfaces:

Container, Destroyable, Dumpable, Dumpable.DumpableContainer, LifeCycle

Direct Known Subclasses:

ClientQuicSession, ServerQuicSession

public abstract class QuicSession
extends ContainerLifeCycle

Represents a logical connection with a remote peer, identified by a QUIC connection ID.

Each QuicSession maintains a number of QUIC streams, identified by their QUIC stream ID; Each QUIC stream is wrapped in an EndPoint, namely QuicStreamEndPoint.

Bytes received from a QuicConnection in process(SocketAddress, ByteBuffer) are passed to Quiche for processing; in turn, Quiche produces a list of QUIC stream IDs that have pending I/O events, either read-ready or write-ready.

On the receive side, a QuicSession fans-out to multiple QuicStreamEndPoints.

On the send side, many QuicStreamEndPoints fan-in to a QuicSession.

See Also:

• ProtocolSession

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	QuicSession.Listener	A listener for QuicSession events.

Nested classes/interfaces inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

AbstractLifeCycle.AbstractLifeCycleListener, AbstractLifeCycle.StopException

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Container

Container.InheritedListener

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Dumpable

Dumpable.DumpableContainer

Field Summary

Fields inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

FAILED, STARTED, STARTING, STOPPED, STOPPING

Fields inherited from interface org.eclipse.jetty.util.component.Dumpable

KEY

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	QuicSession(Executor executor, Scheduler scheduler, ByteBufferPool byteBufferPool, org.eclipse.jetty.quic.quiche.QuicheConnection quicheConnection, QuicConnection connection, SocketAddress remoteAddress)

Method Summary

Modifier and Type	Method	Description
protected abstract ProtocolSession	createProtocolSession()
protected void	doStart()	Starts the managed lifecycle beans in the order they were added.
protected void	doStop()	Stops the managed lifecycle beans in the reverse order they were added.
void	dump(Appendable out, String indent)	Dump this object (and children) into an Appendable using the provided indent after any new lines.
int	fill(long streamId, ByteBuffer buffer)
void	flush()
int	flush(long streamId, ByteBuffer buffer, boolean last)
ByteBufferPool	getByteBufferPool()
org.eclipse.jetty.quic.quiche.QuicheConnectionId	getConnectionId()
Executor	getExecutor()
long	getIdleTimeout()
SocketAddress	getLocalAddress()
int	getMaxLocalStreams()
String	getNegotiatedProtocol()
QuicStreamEndPoint	getOrCreateStreamEndPoint(long streamId, Consumer<QuicStreamEndPoint> consumer)
ProtocolSession	getProtocolSession()
QuicConnection	getQuicConnection()
Collection<QuicStreamEndPoint>	getQuicStreamEndPoints()
SocketAddress	getRemoteAddress()
CloseInfo	getRemoteCloseInfo()
Scheduler	getScheduler()
long	getWindowCapacity()
long	getWindowCapacity(long streamId)
void	inwardClose(long error, String reason)
boolean	isConnectionEstablished()
boolean	isFinished(long streamId)
abstract Connection	newConnection(QuicStreamEndPoint endPoint)
long	newStreamId(StreamType streamType)
void	onFailure(Throwable failure)
boolean	onIdleTimeout()
void	outwardClose(long error, String reason)
protected Runnable	pollTask()
Runnable	process(SocketAddress remoteAddress, ByteBuffer cipherBufferIn)
void	remove(QuicStreamEndPoint endPoint, Throwable failure)
void	setConnectionId(org.eclipse.jetty.quic.quiche.QuicheConnectionId quicheConnectionId)
void	setIdleTimeout(long idleTimeout)
CompletableFuture<Void>	shutdown()
void	shutdownInput(long streamId, long error)
void	shutdownOutput(long streamId, long error)
String	toString()

Methods inherited from class org.eclipse.jetty.util.component.ContainerLifeCycle

addBean, addBean, addEventListener, addManaged, contains, destroy, dump, dump, dumpObjects, dumpStdErr, getBean, getBeans, getBeans, getContainedBeans, getContainedBeans, isAuto, isManaged, isUnmanaged, manage, removeBean, removeBeans, removeEventListener, setBeans, start, stop, unmanage, updateBean, updateBean, updateBeans, updateBeans

Methods inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

getEventListeners, getState, getState, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, setEventListeners, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.eclipse.jetty.util.component.Container

getCachedBeans, getEventListeners

Methods inherited from interface org.eclipse.jetty.util.component.Dumpable

dumpSelf

Methods inherited from interface org.eclipse.jetty.util.component.Dumpable.DumpableContainer

isDumpable

Constructor Details

QuicSession

protected QuicSession(Executor executor,
 Scheduler scheduler,
 ByteBufferPool byteBufferPool,
 org.eclipse.jetty.quic.quiche.QuicheConnection quicheConnection,
 QuicConnection connection,
 SocketAddress remoteAddress)

Method Details

doStart

protected void doStart()
                throws Exception

Description copied from class: ContainerLifeCycle

Starts the managed lifecycle beans in the order they were added.

Overrides:

doStart in class ContainerLifeCycle

Throws:

Exception - If there was a problem starting. Will cause a transition to FAILED state

doStop

protected void doStop()
               throws Exception

Description copied from class: ContainerLifeCycle

Stops the managed lifecycle beans in the reverse order they were added.

Overrides:

doStop in class ContainerLifeCycle

Throws:

Exception - If there was a problem stopping. Will cause a transition to FAILED state

shutdown

public CompletableFuture<Void> shutdown()

getExecutor

public Executor getExecutor()

getScheduler

public Scheduler getScheduler()

getByteBufferPool

public ByteBufferPool getByteBufferPool()

getProtocolSession

public ProtocolSession getProtocolSession()

getMaxLocalStreams

public int getMaxLocalStreams()

getNegotiatedProtocol

public String getNegotiatedProtocol()

getQuicConnection

public QuicConnection getQuicConnection()

getQuicStreamEndPoints

public Collection<QuicStreamEndPoint> getQuicStreamEndPoints()

getRemoteCloseInfo

public CloseInfo getRemoteCloseInfo()

getIdleTimeout

public long getIdleTimeout()

setIdleTimeout

public void setIdleTimeout(long idleTimeout)

onIdleTimeout

public boolean onIdleTimeout()

onFailure

public void onFailure(Throwable failure)

newStreamId

public long newStreamId(StreamType streamType)

Parameters:

streamType - the stream type

Returns:

a new stream ID for the given type

fill

public int fill(long streamId,
 ByteBuffer buffer)
         throws IOException

Throws:

IOException

flush

public int flush(long streamId,
 ByteBuffer buffer,
 boolean last)
          throws IOException

Throws:

IOException

isFinished

public boolean isFinished(long streamId)

getWindowCapacity

public long getWindowCapacity()

getWindowCapacity

public long getWindowCapacity(long streamId)
                       throws IOException

Throws:

IOException

shutdownInput

public void shutdownInput(long streamId,
 long error)
                   throws IOException

Throws:

IOException

shutdownOutput

public void shutdownOutput(long streamId,
 long error)
                    throws IOException

Throws:

IOException

remove

public void remove(QuicStreamEndPoint endPoint,
 Throwable failure)

getLocalAddress

public SocketAddress getLocalAddress()

getRemoteAddress

public SocketAddress getRemoteAddress()

isConnectionEstablished

public boolean isConnectionEstablished()

getConnectionId

public org.eclipse.jetty.quic.quiche.QuicheConnectionId getConnectionId()

setConnectionId

public void setConnectionId(org.eclipse.jetty.quic.quiche.QuicheConnectionId quicheConnectionId)

process

public Runnable process(SocketAddress remoteAddress,
 ByteBuffer cipherBufferIn)
                 throws IOException

Throws:

IOException

pollTask

protected Runnable pollTask()

createProtocolSession

protected abstract ProtocolSession createProtocolSession()

newConnection

public abstract Connection newConnection(QuicStreamEndPoint endPoint)

flush

public void flush()

getOrCreateStreamEndPoint

public QuicStreamEndPoint getOrCreateStreamEndPoint(long streamId,
 Consumer<QuicStreamEndPoint> consumer)

inwardClose

public void inwardClose(long error,
 String reason)

outwardClose

public void outwardClose(long error,
 String reason)

dump

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

Description copied from interface: Dumpable

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.

Specified by:

dump in interface Dumpable

Overrides:

dump in class ContainerLifeCycle

Parameters:

out - The appendable to dump to

indent - The indent to apply after any new lines.

Throws:

IOException - if unable to write to Appendable

toString

public String toString()

Overrides:

toString in class AbstractLifeCycle