Class ClientQuicConnection

java.lang.Object

org.eclipse.jetty.io.AbstractConnection

org.eclipse.jetty.quic.common.QuicConnection

org.eclipse.jetty.quic.client.ClientQuicConnection

All Implemented Interfaces:

Closeable, AutoCloseable, Connection, Invocable

public class ClientQuicConnection
extends QuicConnection

The client specific implementation of QuicConnection.

For each ClientConnector.connect(SocketAddress, Map) operation, a new DatagramChannelEndPoint is created with an associated ClientQuicConnection.

Nested Class Summary

Nested classes/interfaces inherited from interface Connection

Connection.Listener, Connection.UpgradeFrom, Connection.UpgradeTo

Nested classes/interfaces inherited from interface Invocable

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

Field Summary

Fields inherited from interface Invocable

__nonBlocking, NOOP

Constructor Summary

Constructors

Constructor	Description
ClientQuicConnection(ClientConnector connector, EndPoint endPoint, Map<String,Object> context)

Method Summary

Modifier and Type	Method	Description
protected QuicSession	createSession(SocketAddress remoteAddress, ByteBuffer cipherBuffer)
InetSocketAddress	getLocalInetSocketAddress()
protected void	onFailure(Throwable failure)
void	onFillable()	Callback method invoked when the endpoint is ready to be read.
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)

Methods inherited from class QuicConnection

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

Methods inherited from class AbstractConnection

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

Methods inherited from class Object

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

Constructor Details

ClientQuicConnection

public ClientQuicConnection(ClientConnector connector,
 EndPoint endPoint,
 Map<String,Object> context)

Method Details

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

onFillable

public void onFillable()

Description copied from class: AbstractConnection

Callback method invoked when the endpoint is ready to be read.

Overrides:

onFillable in class QuicConnection

See Also:

• AbstractConnection.fillInterested()

createSession

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

Specified by:

createSession in class QuicConnection

Throws:

IOException

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

onFailure

protected void onFailure(Throwable failure)

Overrides:

onFailure in class QuicConnection

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