Package org.eclipse.jetty.http2.client.transport.internal

Class HttpConnectionOverHTTP2

java.lang.Object

org.eclipse.jetty.client.transport.HttpConnection

org.eclipse.jetty.http2.client.transport.internal.HttpConnectionOverHTTP2

All Implemented Interfaces:

Closeable, AutoCloseable, Connection, ConnectionPool.MaxMultiplexable, IConnection, Attachable, Sweeper.Sweepable

public class HttpConnectionOverHTTP2
extends HttpConnection
implements Sweeper.Sweepable, ConnectionPool.MaxMultiplexable

Constructor Summary

Constructors

Constructor	Description
HttpConnectionOverHTTP2(Destination destination, Session session, HTTP2Connection connection)

Method Summary

Modifier and Type	Method	Description
protected HttpChannelOverHTTP2	acquireHttpChannel()
void	close()
protected void	close(Throwable failure)
protected Iterator<HttpChannel>	getHttpChannels()
SocketAddress	getLocalSocketAddress()
int	getMaxMultiplex()
SocketAddress	getRemoteSocketAddress()
Session	getSession()
boolean	isClosed()
boolean	isRecycleHttpChannels()
protected HttpChannelOverHTTP2	newHttpChannel()
protected void	normalizeRequest(HttpRequest request)
boolean	onIdleTimeout(long idleTimeout, Throwable failure)
protected boolean	release(HttpChannelOverHTTP2 channel)
SendFailure	send(HttpExchange exchange)
void	setRecycleHttpChannels(boolean recycleHttpChannels)
boolean	sweep()
String	toString()
void	upgrade(Map<String,Object> context)

Methods inherited from class org.eclipse.jetty.client.transport.HttpConnection

destroy, getAttachment, getHttpClient, getHttpDestination, send, send, setAttachment

Methods inherited from class java.lang.Object

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

Constructor Details

HttpConnectionOverHTTP2

public HttpConnectionOverHTTP2(Destination destination,
 Session session,
 HTTP2Connection connection)

Method Details

getSession

public Session getSession()

getLocalSocketAddress

public SocketAddress getLocalSocketAddress()

Specified by:

getLocalSocketAddress in interface Connection

Returns:

the local socket address associated with the connection

getRemoteSocketAddress

public SocketAddress getRemoteSocketAddress()

Specified by:

getRemoteSocketAddress in interface Connection

Returns:

the remote socket address associated with the connection

isRecycleHttpChannels

public boolean isRecycleHttpChannels()

setRecycleHttpChannels

public void setRecycleHttpChannels(boolean recycleHttpChannels)

getMaxMultiplex

public int getMaxMultiplex()

Specified by:

getMaxMultiplex in interface ConnectionPool.MaxMultiplexable

Returns:

the max number of requests multiplexable on a single connection

getHttpChannels

protected Iterator<HttpChannel> getHttpChannels()

Specified by:

getHttpChannels in class HttpConnection

send

public SendFailure send(HttpExchange exchange)

Specified by:

send in interface IConnection

upgrade

public void upgrade(Map<String,Object> context)

normalizeRequest

protected void normalizeRequest(HttpRequest request)

Overrides:

normalizeRequest in class HttpConnection

acquireHttpChannel

protected HttpChannelOverHTTP2 acquireHttpChannel()

newHttpChannel

protected HttpChannelOverHTTP2 newHttpChannel()

release

protected boolean release(HttpChannelOverHTTP2 channel)

onIdleTimeout

public boolean onIdleTimeout(long idleTimeout,
 Throwable failure)

Overrides:

onIdleTimeout in class HttpConnection

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Connection

close

protected void close(Throwable failure)

isClosed

public boolean isClosed()

Specified by:

isClosed in interface Connection

Returns:

whether this connection has been closed

See Also:

• Connection.close()

sweep

public boolean sweep()

Specified by:

sweep in interface Sweeper.Sweepable

Returns:

whether this resource should be swept

toString

public String toString()

Overrides:

toString in class HttpConnection