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
All Methods Instance Methods Concrete Methods 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
-
-
-
-
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 interfaceorg.eclipse.jetty.client.ConnectionPool.Multiplexable
-
getHttpChannels
protected java.util.Iterator<org.eclipse.jetty.client.HttpChannel> getHttpChannels()
- Specified by:
getHttpChannels
in classorg.eclipse.jetty.client.HttpConnection
-
send
protected org.eclipse.jetty.client.SendFailure send(org.eclipse.jetty.client.HttpExchange exchange)
- Specified by:
send
in classorg.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 classorg.eclipse.jetty.client.HttpConnection
-
remove
void remove()
-
close
public void close()
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Specified by:
close
in interfaceorg.eclipse.jetty.client.api.Connection
-
close
protected void close(java.lang.Throwable failure)
-
isClosed
public boolean isClosed()
- Specified by:
isClosed
in interfaceorg.eclipse.jetty.client.api.Connection
-
abort
private void abort(java.lang.Throwable failure)
-
sweep
public boolean sweep()
- Specified by:
sweep
in interfaceorg.eclipse.jetty.util.thread.Sweeper.Sweepable
-
toString
public java.lang.String toString()
- Overrides:
toString
in classorg.eclipse.jetty.client.HttpConnection
-
-