Top Description Fields Constructors Methods
org.eclipse.jetty.quic.client

public Class ClientQuicConnection

extends QuicConnection
Class Inheritance
Imports
java.io.IOException, java.net.InetSocketAddress, .SocketAddress, .SocketTimeoutException, java.nio.ByteBuffer, java.util.Collection, .List, .Map, java.util.concurrent.ConcurrentHashMap, .TimeUnit, .TimeoutException, org.eclipse.jetty.io.ClientConnector, .DatagramChannelEndPoint, .EndPoint, .RuntimeIOException, org.eclipse.jetty.quic.common.QuicConfiguration, .QuicConnection, .QuicSession, org.eclipse.jetty.quic.quiche.QuicheConfig, .QuicheConnection, org.eclipse.jetty.util.Promise, org.eclipse.jetty.util.thread.Scheduler, org.slf4j.Logger, .LoggerFactory

The client specific implementation of QuicConnection.

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

Field Summary

Modifier and TypeField and Description
private final ClientConnector
connector

private Scheduler.Task
connectTask

private final Map<String, Object>
context

private static final Logger
LOG

Hides org.eclipse.jetty.quic.common.QuicConnection.LOG.

private final Map<SocketAddress, ClientQuicSession>
pendingSessions

Constructor Summary

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

Method Summary

Modifier and TypeMethod and Description
private void
connectTimeout(SocketAddress remoteAddress)

protected QuicSession
createSession(SocketAddress remoteAddress, ByteBuffer cipherBuffer)

Implements abstract org.eclipse.jetty.quic.common.QuicConnection.createSession.

protected void
onFailure(Throwable failure)

Overrides org.eclipse.jetty.quic.common.QuicConnection.onFailure.

public void
onFillable()

Overrides org.eclipse.jetty.quic.common.QuicConnection.onFillable.

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

public boolean
onIdleExpired(TimeoutException timeoutException)

Implements abstract org.eclipse.jetty.quic.common.QuicConnection.onIdleExpired.

Implements org.eclipse.jetty.io.Connection.onIdleExpired.

Callback method invoked upon an idle timeout event.

public void
onOpen()

Overrides org.eclipse.jetty.quic.common.QuicConnection.onOpen.

Implements org.eclipse.jetty.io.Connection.onOpen.

Callback method invoked when this connection is opened.

public void
outwardClose(QuicSession session, Throwable failure)

Overrides org.eclipse.jetty.quic.common.QuicConnection.outwardClose.

private void
outwardClose(SocketAddress remoteAddress, Throwable failure)

Inherited from org.eclipse.jetty.quic.common.QuicConnection:
addEventListenerclosefillInterestedgetByteBufferPoolgetEndPointgetOutputBufferSizegetQuicSessionsgetSchedulerisUseInputDirectByteBuffersisUseOutputDirectByteBuffersonCloseremoveEventListenersetOutputBufferSizesetUseInputDirectByteBufferssetUseOutputDirectByteBufferswrite

Field Detail

connectorback to summary
private final ClientConnector connector
connectTaskback to summary
private Scheduler.Task connectTask
contextback to summary
private final Map<String, Object> context
LOGback to summary
private static final Logger LOG

Hides org.eclipse.jetty.quic.common.QuicConnection.LOG.

pendingSessionsback to summary
private final Map<SocketAddress, ClientQuicSession> pendingSessions

Constructor Detail

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

Method Detail

connectTimeoutback to summary
private void connectTimeout(SocketAddress remoteAddress)
createSessionback to summary
protected QuicSession createSession(SocketAddress remoteAddress, ByteBuffer cipherBuffer) throws IOException

Implements abstract org.eclipse.jetty.quic.common.QuicConnection.createSession.

Annotations
@Override
onFailureback to summary
protected void onFailure(Throwable failure)

Overrides org.eclipse.jetty.quic.common.QuicConnection.onFailure.

Annotations
@Override
onFillableback to summary
public void onFillable()

Overrides org.eclipse.jetty.quic.common.QuicConnection.onFillable.

Doc from org.eclipse.jetty.io.AbstractConnection.onFillable.

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

Annotations
@Override
onIdleExpiredback to summary
public boolean onIdleExpired(TimeoutException timeoutException)

Implements abstract org.eclipse.jetty.quic.common.QuicConnection.onIdleExpired.

Implements org.eclipse.jetty.io.Connection.onIdleExpired.

Doc from org.eclipse.jetty.io.Connection.onIdleExpired.

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.

Annotations
@Override
onOpenback to summary
public void onOpen()

Overrides org.eclipse.jetty.quic.common.QuicConnection.onOpen.

Implements org.eclipse.jetty.io.Connection.onOpen.

Doc from org.eclipse.jetty.io.Connection.onOpen.

Callback method invoked when this connection is opened.

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

Annotations
@Override
outwardCloseback to summary
public void outwardClose(QuicSession session, Throwable failure)

Overrides org.eclipse.jetty.quic.common.QuicConnection.outwardClose.

Annotations
@Override
outwardCloseback to summary
private void outwardClose(SocketAddress remoteAddress, Throwable failure)