Class ServerQuicSession

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.component.ContainerLifeCycle

org.eclipse.jetty.quic.common.QuicSession

org.eclipse.jetty.quic.server.ServerQuicSession

All Implemented Interfaces:

CyclicTimeouts.Expirable, Container, Destroyable, Dumpable, Dumpable.DumpableContainer, LifeCycle

public class ServerQuicSession
extends QuicSession
implements CyclicTimeouts.Expirable

The server specific implementation of QuicSession.

When asked to create a QUIC stream, it creates a QuicStreamEndPoint with an associated Connection created from the ConnectionFactory, retrieved from the server Connector, correspondent to the protocol negotiated with the client (or the default protocol).

Nested Class Summary

Nested classes/interfaces inherited from class QuicSession

QuicSession.Listener

Nested classes/interfaces inherited from class AbstractLifeCycle

AbstractLifeCycle.AbstractLifeCycleListener, AbstractLifeCycle.StopException

Nested classes/interfaces inherited from interface Container

Container.InheritedListener

Nested classes/interfaces inherited from interface Dumpable

Dumpable.DumpableContainer

Field Summary

Fields inherited from class AbstractLifeCycle

FAILED, STARTED, STARTING, STOPPED, STOPPING

Fields inherited from interface Dumpable

KEY

Constructor Summary

Constructors

Constructor	Description
ServerQuicSession(Executor executor, Scheduler scheduler, ByteBufferPool bufferPool, QuicheConnection quicheConnection, ServerQuicConnection connection, SocketAddress remoteAddress, Connector connector)

Method Summary

Modifier and Type	Method	Description
protected ProtocolSession	createProtocolSession()
void	flush()
long	getExpireNanoTime()	Returns the expiration time in nanoseconds.
ServerQuicConnection	getQuicConnection()
Connection	newConnection(QuicStreamEndPoint endPoint)
boolean	onIdleTimeout()
Runnable	process(SocketAddress remoteAddress, ByteBuffer cipherBufferIn)
void	setIdleTimeout(long idleTimeout)
protected boolean	validateNewlyEstablishedConnection()

Methods inherited from class QuicSession

doStart, doStop, dump, fill, flush, getByteBufferPool, getConnectionId, getExecutor, getIdleTimeout, getLocalAddress, getMaxLocalStreams, getNegotiatedProtocol, getOrCreateStreamEndPoint, getPeerCertificates, getProtocolSession, getQuicStreamEndPoints, getRemoteAddress, getRemoteCloseInfo, getScheduler, getWindowCapacity, getWindowCapacity, inwardClose, isConnectionEstablished, isFinished, newStreamId, onFailure, outwardClose, pollTask, remove, setConnectionId, shutdown, shutdownInput, shutdownOutput, toString

Methods inherited from class ContainerLifeCycle

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

Methods inherited from class AbstractLifeCycle

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

Methods inherited from class Object

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

Methods inherited from interface Container

getCachedBeans, getEventListeners

Methods inherited from interface Dumpable

dumpSelf

Methods inherited from interface Dumpable.DumpableContainer

isDumpable

Constructor Details

ServerQuicSession

public ServerQuicSession(Executor executor,
 Scheduler scheduler,
 ByteBufferPool bufferPool,
 QuicheConnection quicheConnection,
 ServerQuicConnection connection,
 SocketAddress remoteAddress,
 Connector connector)

Method Details

getQuicConnection

public ServerQuicConnection getQuicConnection()

Overrides:

getQuicConnection in class QuicSession

createProtocolSession

protected ProtocolSession createProtocolSession()

Specified by:

createProtocolSession in class QuicSession

validateNewlyEstablishedConnection

protected boolean validateNewlyEstablishedConnection()

Specified by:

validateNewlyEstablishedConnection in class QuicSession

Returns:

true if the connection is valid, false otherwise.

newConnection

public Connection newConnection(QuicStreamEndPoint endPoint)

Specified by:

newConnection in class QuicSession

getExpireNanoTime

public long getExpireNanoTime()

Description copied from interface: CyclicTimeouts.Expirable

Returns the expiration time in nanoseconds.

The value to return must be calculated taking into account the current nanoTime, for example:

expireNanoTime = NanoTime.now() + timeoutNanos

Returning Long.MAX_VALUE indicates that this entity does not expire.

Specified by:

getExpireNanoTime in interface CyclicTimeouts.Expirable

Returns:

the expiration time in nanoseconds, or Long.MAX_VALUE if this entity does not expire

setIdleTimeout

public void setIdleTimeout(long idleTimeout)

Overrides:

setIdleTimeout in class QuicSession

onIdleTimeout

public boolean onIdleTimeout()

Overrides:

onIdleTimeout in class QuicSession

process

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

Overrides:

process in class QuicSession

Throws:

IOException

flush

public void flush()

Overrides:

flush in class QuicSession