Package org.eclipse.jetty.http2.client.http

Class HttpConnectionOverHTTP2

java.lang.Object

org.eclipse.jetty.client.HttpConnection

org.eclipse.jetty.http2.client.http.HttpConnectionOverHTTP2

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, org.eclipse.jetty.client.api.Connection, org.eclipse.jetty.client.ConnectionPool.Multiplexable, org.eclipse.jetty.util.Attachable, org.eclipse.jetty.util.thread.Sweeper.Sweepable

public class HttpConnectionOverHTTP2
extends org.eclipse.jetty.client.HttpConnection
implements org.eclipse.jetty.util.thread.Sweeper.Sweepable, org.eclipse.jetty.client.ConnectionPool.Multiplexable

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.Set<org.eclipse.jetty.client.HttpChannel>	activeChannels
private java.util.concurrent.atomic.AtomicBoolean	closed
private java.util.Queue<HttpChannelOverHTTP2>	idleChannels
private static org.eclipse.jetty.util.log.Logger	LOG
private boolean	recycleHttpChannels
private Session	session
private java.util.concurrent.atomic.AtomicInteger	sweeps

Constructor Summary

Constructors

Constructor	Description
HttpConnectionOverHTTP2(org.eclipse.jetty.client.HttpDestination destination, Session session)

Method Summary

Modifier and Type	Method	Description
private void	abort(java.lang.Throwable failure)
protected HttpChannelOverHTTP2	acquireHttpChannel()
void	close()
protected void	close(java.lang.Throwable failure)
protected java.util.Iterator<org.eclipse.jetty.client.HttpChannel>	getHttpChannels()
int	getMaxMultiplex()
Session	getSession()
boolean	isClosed()
boolean	isRecycleHttpChannels()
protected HttpChannelOverHTTP2	newHttpChannel()
boolean	onIdleTimeout(long idleTimeout)
protected boolean	release(HttpChannelOverHTTP2 channel)
(package private) void	remove()
protected org.eclipse.jetty.client.SendFailure	send(org.eclipse.jetty.client.HttpExchange exchange)
void	setRecycleHttpChannels(boolean recycleHttpChannels)
boolean	sweep()
java.lang.String	toString()

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

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.jetty.client.ConnectionPool.Multiplexable

setMaxMultiplex

Field Detail

LOG

private static final org.eclipse.jetty.util.log.Logger LOG

activeChannels

private final java.util.Set<org.eclipse.jetty.client.HttpChannel> activeChannels

idleChannels

private final java.util.Queue<HttpChannelOverHTTP2> idleChannels

closed

private final java.util.concurrent.atomic.AtomicBoolean closed

sweeps

private final java.util.concurrent.atomic.AtomicInteger sweeps

session

private final Session session

recycleHttpChannels

private boolean recycleHttpChannels

Constructor Detail

HttpConnectionOverHTTP2

public HttpConnectionOverHTTP2(org.eclipse.jetty.client.HttpDestination destination,
                               Session session)

Method Detail

getSession

public Session getSession()

isRecycleHttpChannels

public boolean isRecycleHttpChannels()

setRecycleHttpChannels

public void setRecycleHttpChannels(boolean recycleHttpChannels)

getMaxMultiplex

public int getMaxMultiplex()

Specified by:

getMaxMultiplex in interface org.eclipse.jetty.client.ConnectionPool.Multiplexable

getHttpChannels

protected java.util.Iterator<org.eclipse.jetty.client.HttpChannel> getHttpChannels()

Specified by:

getHttpChannels in class org.eclipse.jetty.client.HttpConnection

send

protected org.eclipse.jetty.client.SendFailure send(org.eclipse.jetty.client.HttpExchange exchange)

Specified by:

send in class org.eclipse.jetty.client.HttpConnection

acquireHttpChannel

protected HttpChannelOverHTTP2 acquireHttpChannel()

newHttpChannel

protected HttpChannelOverHTTP2 newHttpChannel()

release

protected boolean release(HttpChannelOverHTTP2 channel)

onIdleTimeout

public boolean onIdleTimeout(long idleTimeout)

Overrides:

onIdleTimeout in class org.eclipse.jetty.client.HttpConnection

remove

void remove()

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface org.eclipse.jetty.client.api.Connection

close

protected void close(java.lang.Throwable failure)

isClosed

public boolean isClosed()

Specified by:

isClosed in interface org.eclipse.jetty.client.api.Connection

abort

private void abort(java.lang.Throwable failure)

sweep

public boolean sweep()

Specified by:

sweep in interface org.eclipse.jetty.util.thread.Sweeper.Sweepable

toString

public java.lang.String toString()

Overrides:

toString in class org.eclipse.jetty.client.HttpConnection