Top Fields Constructors Methods
org.eclipse.jetty.http3.client.transport.internal

public Class HttpConnectionOverHTTP3

extends HttpConnection
implements MaxMultiplexable, MaxUsable
Class Inheritance
All Implemented Interfaces
org.eclipse.jetty.client.ConnectionPool.MaxUsable, org.eclipse.jetty.client.ConnectionPool.MaxMultiplexable
Imports
java.net.SocketAddress, java.nio.channels.AsynchronousCloseException, java.util.Iterator, .Set, java.util.concurrent.ConcurrentHashMap, java.util.concurrent.atomic.AtomicBoolean, org.eclipse.jetty.client.ConnectionPool, .Destination, org.eclipse.jetty.client.transport.HttpChannel, .HttpConnection, .HttpDestination, .HttpExchange, .HttpRequest, .SendFailure, org.eclipse.jetty.http.HttpVersion, org.eclipse.jetty.http3.client.HTTP3SessionClient, org.slf4j.Logger, .LoggerFactory

Field Summary

Modifier and TypeField and Description
private final Set<HttpChannel>
activeChannels

private final AtomicBoolean
closed

private static final Logger
LOG

Hides org.eclipse.jetty.client.transport.HttpConnection.LOG.

private final HTTP3SessionClient
session

Constructor Summary

AccessConstructor and Description
public
HttpConnectionOverHTTP3(Destination destination, HTTP3SessionClient session)

Method Summary

Modifier and TypeMethod and Description
private void
abort(Throwable failure)

public void
close()

Implements org.eclipse.jetty.client.Connection.close.

Closes this stream and releases any system resources associated with it.

public void
close(Throwable failure)

protected Iterator<HttpChannel>
getHttpChannels()

Implements abstract org.eclipse.jetty.client.transport.HttpConnection.getHttpChannels.

public SocketAddress
getLocalSocketAddress()

Overrides default org.eclipse.jetty.client.Connection.getLocalSocketAddress.

public int
getMaxMultiplex()

Implements org.eclipse.jetty.client.ConnectionPool.MaxMultiplexable.getMaxMultiplex.

public int
getMaxUsage()

Implements org.eclipse.jetty.client.ConnectionPool.MaxUsable.getMaxUsage.

public SocketAddress
getRemoteSocketAddress()

Overrides default org.eclipse.jetty.client.Connection.getRemoteSocketAddress.

public HTTP3SessionClient
getSession()

public boolean
isClosed()

Implements org.eclipse.jetty.client.Connection.isClosed.

protected HttpChannelOverHTTP3
newHttpChannel()

public boolean
onIdleTimeout(long idleTimeout, Throwable failure)

Overrides org.eclipse.jetty.client.transport.HttpConnection.onIdleTimeout.

public void
release(HttpChannelOverHTTP3 channel)

public SendFailure
send(HttpExchange exchange)

Implements org.eclipse.jetty.client.transport.IConnection.send.

Inherited from org.eclipse.jetty.client.transport.HttpConnection:
destroygetAttachmentgetHttpClientgetHttpDestinationnormalizeRequestsendsendsetAttachmenttoString

Field Detail

activeChannelsback to summary
private final Set<HttpChannel> activeChannels
closedback to summary
private final AtomicBoolean closed
LOGback to summary
private static final Logger LOG

Hides org.eclipse.jetty.client.transport.HttpConnection.LOG.

sessionback to summary
private final HTTP3SessionClient session

Constructor Detail

HttpConnectionOverHTTP3back to summary
public HttpConnectionOverHTTP3(Destination destination, HTTP3SessionClient session)

Method Detail

abortback to summary
private void abort(Throwable failure)
closeback to summary
public void close()

Implements org.eclipse.jetty.client.Connection.close.

Doc from java.io.Closeable.close.

Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect.

As noted in AutoCloseable#close(), cases where the close may fail require careful attention. It is strongly advised to relinquish the underlying resources and to internally mark the Closeable as closed, prior to throwing the IOException.

Annotations
@Override
closeback to summary
public void close(Throwable failure)
getHttpChannelsback to summary
protected Iterator<HttpChannel> getHttpChannels()

Implements abstract org.eclipse.jetty.client.transport.HttpConnection.getHttpChannels.

Annotations
@Override
getLocalSocketAddressback to summary
public SocketAddress getLocalSocketAddress()

Overrides default org.eclipse.jetty.client.Connection.getLocalSocketAddress.

Annotations
@Override
getMaxMultiplexback to summary
public int getMaxMultiplex()

Implements org.eclipse.jetty.client.ConnectionPool.MaxMultiplexable.getMaxMultiplex.

Annotations
@Override
getMaxUsageback to summary
public int getMaxUsage()

Implements org.eclipse.jetty.client.ConnectionPool.MaxUsable.getMaxUsage.

Annotations
@Override
getRemoteSocketAddressback to summary
public SocketAddress getRemoteSocketAddress()

Overrides default org.eclipse.jetty.client.Connection.getRemoteSocketAddress.

Annotations
@Override
getSessionback to summary
public HTTP3SessionClient getSession()
isClosedback to summary
public boolean isClosed()

Implements org.eclipse.jetty.client.Connection.isClosed.

Annotations
@Override
newHttpChannelback to summary
protected HttpChannelOverHTTP3 newHttpChannel()
onIdleTimeoutback to summary
public boolean onIdleTimeout(long idleTimeout, Throwable failure)

Overrides org.eclipse.jetty.client.transport.HttpConnection.onIdleTimeout.

Annotations
@Override
releaseback to summary
public void release(HttpChannelOverHTTP3 channel)
sendback to summary
public SendFailure send(HttpExchange exchange)

Implements org.eclipse.jetty.client.transport.IConnection.send.

Annotations
@Override