Package org.eclipse.jetty.quic.server

Class ServerQuicConnection

java.lang.Object

org.eclipse.jetty.io.AbstractConnection

org.eclipse.jetty.quic.common.QuicConnection

org.eclipse.jetty.quic.server.ServerQuicConnection

All Implemented Interfaces:

Closeable, AutoCloseable, Connection, Invocable

public class ServerQuicConnection
extends QuicConnection

The server specific implementation of QuicConnection.

Nested Class Summary

Nested classes/interfaces inherited from interface org.eclipse.jetty.io.Connection

Connection.Listener, Connection.UpgradeFrom, Connection.UpgradeTo

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.thread.Invocable

Invocable.Callable, Invocable.InvocationType, Invocable.ReadyTask, Invocable.Task

Field Summary

Fields inherited from interface org.eclipse.jetty.util.thread.Invocable

__nonBlocking, NOOP

Constructor Summary

Constructors

Constructor	Description
ServerQuicConnection(Connector connector, ServerQuicConfiguration quicConfiguration, EndPoint endPoint)

Method Summary

Modifier and Type	Method	Description
protected QuicSession	createSession(SocketAddress remoteAddress, ByteBuffer cipherBuffer)
InetSocketAddress	getLocalInetSocketAddress()
Connector	getQuicServerConnector()
protected ServerQuicSession	newQuicSession(SocketAddress remoteAddress, org.eclipse.jetty.quic.quiche.QuicheConnection quicheConnection)
boolean	onIdleExpired(TimeoutException timeoutException)	Callback method invoked upon an idle timeout event.
void	onOpen()	Callback method invoked when this connection is opened.
void	outwardClose(QuicSession session, Throwable failure)
protected Runnable	process(QuicSession session, SocketAddress remoteAddress, ByteBuffer cipherBuffer)
void	schedule(ServerQuicSession session)

Methods inherited from class org.eclipse.jetty.quic.common.QuicConnection

addEventListener, close, fillInterested, getByteBufferPool, getOutputBufferSize, getQuicSessions, getScheduler, isUseInputDirectByteBuffers, isUseOutputDirectByteBuffers, onClose, onFailure, onFillable, removeEventListener, setOutputBufferSize, setUseInputDirectByteBuffers, setUseOutputDirectByteBuffers, write

Methods inherited from class org.eclipse.jetty.io.AbstractConnection

failedCallback, getBytesIn, getBytesOut, getCreatedTimeStamp, getEndPoint, getExecutor, getInputBufferSize, getInvocationType, getMessagesIn, getMessagesOut, isFillInterested, onFillInterestedFailed, onReadTimeout, setInputBufferSize, toConnectionString, toString, tryFillInterested

Methods inherited from class java.lang.Object

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

Constructor Details

ServerQuicConnection

public ServerQuicConnection(Connector connector,
 ServerQuicConfiguration quicConfiguration,
 EndPoint endPoint)

Method Details

getQuicServerConnector

public Connector getQuicServerConnector()

onOpen

public void onOpen()

Description copied from interface: Connection

Callback method invoked when this connection is opened.

Creators of the connection implementation are responsible for calling this method.

Specified by:

onOpen in interface Connection

Overrides:

onOpen in class QuicConnection

createSession

protected QuicSession createSession(SocketAddress remoteAddress,
 ByteBuffer cipherBuffer)
                             throws IOException

Specified by:

createSession in class QuicConnection

Throws:

IOException

newQuicSession

protected ServerQuicSession newQuicSession(SocketAddress remoteAddress,
 org.eclipse.jetty.quic.quiche.QuicheConnection quicheConnection)

getLocalInetSocketAddress

public InetSocketAddress getLocalInetSocketAddress()

Specified by:

getLocalInetSocketAddress in class QuicConnection

process

protected Runnable process(QuicSession session,
 SocketAddress remoteAddress,
 ByteBuffer cipherBuffer)

Overrides:

process in class QuicConnection

schedule

public void schedule(ServerQuicSession session)

onIdleExpired

public boolean onIdleExpired(TimeoutException timeoutException)

Description copied from interface: Connection

Callback method invoked upon an idle timeout event.

Implementations of this method may return true to indicate that the idle timeout handling should proceed normally, typically failing the EndPoint and causing it to be closed.

When false is returned, the handling of the idle timeout event is halted immediately and the EndPoint left in the state it was before the idle timeout event.

Specified by:

onIdleExpired in interface Connection

Specified by:

onIdleExpired in class QuicConnection

Returns:

true to let the EndPoint handle the idle timeout, false to tell the EndPoint to halt the handling of the idle timeout.

outwardClose

public void outwardClose(QuicSession session,
 Throwable failure)

Overrides:

outwardClose in class QuicConnection