Package org.eclipse.jetty.quic.client

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

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 org.eclipse.jetty.io.Connection

Connection.Listener, Connection.UpgradeFrom, Connection.UpgradeTo

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)
protected void	onFailure(Throwable failure)
void	onFillable()	Callback method invoked when the endpoint is ready to be read.
boolean	onIdleExpired()	Callback method invoked upon an idle timeout event.
void	onOpen()	Callback method invoked when this connection is opened.
void	outwardClose(QuicSession session, Throwable failure)

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

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

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

failedCallback, getBytesIn, getBytesOut, getCreatedTimeStamp, getExecutor, getInputBufferSize, 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

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

onFailure

protected void onFailure(Throwable failure)

Overrides:

onFailure in class QuicConnection

onIdleExpired

public boolean onIdleExpired()

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