Nested and Inner Type Summary

Modifier and Type	Class and Description
private class	HttpConnectionOverHTTP.Delegate

Field Summary

Modifier and Type	Field and Description
private final LongAdder	bytesIn
private final LongAdder	bytesOut
private final HttpChannelOverHTTP	channel
private final AtomicBoolean	closed
private final HttpConnectionOverHTTP.Delegate	delegate
private long	idleTimeout
private static final Logger	LOG Hides org.eclipse.jetty.io.AbstractConnection.LOG.
private final Promise<Connection>	promise
private final AtomicInteger	sweeps

Constructor Summary

Access	Constructor and Description
public	HttpConnectionOverHTTP(EndPoint endPoint, Map<String, Object> context)
public	HttpConnectionOverHTTP(EndPoint endPoint, HttpDestination destination, Promise<Connection> promise)

Method Summary

Modifier and Type	Method and Description
protected void	abort(Throwable failure, Promise<Boolean> promise)
protected void	addBytesIn(long bytesIn)
protected void	addBytesOut(long bytesOut)
public void	close() Overrides org.eclipse.jetty.io.AbstractConnection.close. Implements org.eclipse.jetty.client.Connection.close, org.eclipse.jetty.io.Connection.close. Closes this stream and releases any system resources associated with it.
protected void	close(Throwable failure)
private static HttpDestination	destinationFrom(Map<String, Object> context)
public Object	getAttachment() Implements org.eclipse.jetty.util.Attachable.getAttachment.
public long	getBytesIn() Overrides org.eclipse.jetty.io.AbstractConnection.getBytesIn. Implements org.eclipse.jetty.io.Connection.getBytesIn.
public long	getBytesOut() Overrides org.eclipse.jetty.io.AbstractConnection.getBytesOut. Implements org.eclipse.jetty.io.Connection.getBytesOut.
public HttpChannelOverHTTP	getHttpChannel()
public HttpDestination	getHttpDestination()
public SocketAddress	getLocalSocketAddress() Overrides default org.eclipse.jetty.client.Connection.getLocalSocketAddress.
public long	getMessagesIn() Overrides org.eclipse.jetty.io.AbstractConnection.getMessagesIn. Implements org.eclipse.jetty.io.Connection.getMessagesIn.
public long	getMessagesOut() Overrides org.eclipse.jetty.io.AbstractConnection.getMessagesOut. Implements org.eclipse.jetty.io.Connection.getMessagesOut.
public SocketAddress	getRemoteSocketAddress() Overrides default org.eclipse.jetty.client.Connection.getRemoteSocketAddress.
public boolean	isClosed() Implements org.eclipse.jetty.client.Connection.isClosed.
protected HttpChannelOverHTTP	newHttpChannel()
public void	onFillable() Implements abstract org.eclipse.jetty.io.AbstractConnection.onFillable. Callback method invoked when the endpoint is ready to be read.
public boolean	onIdleExpired(TimeoutException timeout) Overrides org.eclipse.jetty.io.AbstractConnection.onIdleExpired. Implements org.eclipse.jetty.io.Connection.onIdleExpired. Callback method invoked upon an idle timeout event.
protected boolean	onIdleTimeout(long idleTimeout)
public void	onOpen() Overrides org.eclipse.jetty.io.AbstractConnection.onOpen. Implements org.eclipse.jetty.io.Connection.onOpen. Callback method invoked when this connection is opened.
pack-priv void	onResponseHeaders(HttpExchange exchange)
public ByteBuffer	onUpgradeFrom() Implements org.eclipse.jetty.io.Connection.UpgradeFrom.onUpgradeFrom. Invoked during an `upgrade` to produce a buffer containing bytes that have not been consumed by this connection, and that must be consumed by the upgrade-to connection.
private static Promise<Connection>	promiseFrom(Map<String, Object> context)
public void	release()
public void	remove()
public void	send(Request the request to send request, Response.CompleteListener the response listener listener) Implements org.eclipse.jetty.client.Connection.send. Sends a request with an associated response listener.
public SendFailure	send(HttpExchange exchange) Implements org.eclipse.jetty.client.transport.IConnection.send.
public void	setAttachment(Object the object to attach to this instance obj) Implements org.eclipse.jetty.util.Attachable.setAttachment. Attaches the given object to this stream for later retrieval.
public boolean	sweep() Implements org.eclipse.jetty.util.thread.Sweeper.Sweepable.sweep.
public String	toConnectionString() Overrides org.eclipse.jetty.io.AbstractConnection.toConnectionString.

Inherited from org.eclipse.jetty.io.AbstractConnection:: addEventListener failedCallback fillInterested getCreatedTimeStamp getEndPoint getExecutor getInputBufferSize getInvocationType isFillInterested onClose onFillInterestedFailed onReadTimeout removeEventListener setInputBufferSize toString tryFillInterested

Field Detail

bytesIn	back to summary
private final LongAdder bytesIn

bytesOut	back to summary
private final LongAdder bytesOut

channel	back to summary
private final HttpChannelOverHTTP channel

closed	back to summary
private final AtomicBoolean closed

delegate	back to summary
private final HttpConnectionOverHTTP.Delegate delegate

idleTimeout	back to summary
private long idleTimeout

LOG	back to summary
private static final Logger LOG Hides org.eclipse.jetty.io.AbstractConnection.LOG.

promise	back to summary
private final Promise<Connection> promise

sweeps	back to summary
private final AtomicInteger sweeps

Constructor Detail

HttpConnectionOverHTTP	back to summary
public HttpConnectionOverHTTP(EndPoint endPoint, Map<String, Object> context)

HttpConnectionOverHTTP	back to summary
public HttpConnectionOverHTTP(EndPoint endPoint, HttpDestination destination, Promise<Connection> promise)

Method Detail

abort	back to summary
protected void abort(Throwable failure, Promise<Boolean> promise)

addBytesIn	back to summary
protected void addBytesIn(long bytesIn)

addBytesOut	back to summary
protected void addBytesOut(long bytesOut)

close back to summary

close	back to summary
public void close() Overrides org.eclipse.jetty.io.AbstractConnection.close. Implements org.eclipse.jetty.client.Connection.close, org.eclipse.jetty.io.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

public void close()

Overrides org.eclipse.jetty.io.AbstractConnection.close.

Implements org.eclipse.jetty.client.Connection.close, org.eclipse.jetty.io.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

close	back to summary
protected void close(Throwable failure)

destinationFrom	back to summary
private static HttpDestination destinationFrom(Map<String, Object> context)

getAttachment	back to summary
public Object getAttachment() Implements org.eclipse.jetty.util.Attachable.getAttachment. Returns:Object Doc from org.eclipse.jetty.util.Attachable.getAttachment. the object attached to this instance Annotations @Override

getAttachment

back to summary

public Object getAttachment()

Implements org.eclipse.jetty.util.Attachable.getAttachment.

Returns:Object

Doc from org.eclipse.jetty.util.Attachable.getAttachment.

the object attached to this instance

Annotations

@Override

getBytesIn	back to summary
public long getBytesIn() Overrides org.eclipse.jetty.io.AbstractConnection.getBytesIn. Implements org.eclipse.jetty.io.Connection.getBytesIn. Annotations @Override

getBytesIn

back to summary

public long getBytesIn()

Overrides org.eclipse.jetty.io.AbstractConnection.getBytesIn.

Implements org.eclipse.jetty.io.Connection.getBytesIn.

Annotations

@Override

getBytesOut	back to summary
public long getBytesOut() Overrides org.eclipse.jetty.io.AbstractConnection.getBytesOut. Implements org.eclipse.jetty.io.Connection.getBytesOut. Annotations @Override

getBytesOut

back to summary

public long getBytesOut()

Overrides org.eclipse.jetty.io.AbstractConnection.getBytesOut.

Implements org.eclipse.jetty.io.Connection.getBytesOut.

Annotations

@Override

getHttpChannel	back to summary
public HttpChannelOverHTTP getHttpChannel()

getHttpDestination	back to summary
public HttpDestination getHttpDestination()

getLocalSocketAddress	back to summary
public SocketAddress getLocalSocketAddress() Overrides default org.eclipse.jetty.client.Connection.getLocalSocketAddress. Returns:SocketAddress Doc from org.eclipse.jetty.client.Connection.getLocalSocketAddress. the local socket address associated with the connection Annotations @Override

getLocalSocketAddress

back to summary

public SocketAddress getLocalSocketAddress()

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

Returns:SocketAddress

Doc from org.eclipse.jetty.client.Connection.getLocalSocketAddress.

the local socket address associated with the connection

Annotations

@Override

getMessagesIn	back to summary
public long getMessagesIn() Overrides org.eclipse.jetty.io.AbstractConnection.getMessagesIn. Implements org.eclipse.jetty.io.Connection.getMessagesIn. Annotations @Override

getMessagesIn

back to summary

public long getMessagesIn()

Overrides org.eclipse.jetty.io.AbstractConnection.getMessagesIn.

Implements org.eclipse.jetty.io.Connection.getMessagesIn.

Annotations

@Override

getMessagesOut	back to summary
public long getMessagesOut() Overrides org.eclipse.jetty.io.AbstractConnection.getMessagesOut. Implements org.eclipse.jetty.io.Connection.getMessagesOut. Annotations @Override

getMessagesOut

back to summary

public long getMessagesOut()

Overrides org.eclipse.jetty.io.AbstractConnection.getMessagesOut.

Implements org.eclipse.jetty.io.Connection.getMessagesOut.

Annotations

@Override

getRemoteSocketAddress	back to summary
public SocketAddress getRemoteSocketAddress() Overrides default org.eclipse.jetty.client.Connection.getRemoteSocketAddress. Returns:SocketAddress Doc from org.eclipse.jetty.client.Connection.getRemoteSocketAddress. the remote socket address associated with the connection Annotations @Override

getRemoteSocketAddress

back to summary

public SocketAddress getRemoteSocketAddress()

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

Returns:SocketAddress

Doc from org.eclipse.jetty.client.Connection.getRemoteSocketAddress.

the remote socket address associated with the connection

Annotations

@Override

isClosed	back to summary
public boolean isClosed() Implements org.eclipse.jetty.client.Connection.isClosed. Returns:boolean Doc from org.eclipse.jetty.client.Connection.isClosed. whether this connection has been closed Annotations @Override

isClosed

back to summary

public boolean isClosed()

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

Returns:boolean

Doc from org.eclipse.jetty.client.Connection.isClosed.

whether this connection has been closed

Annotations

@Override

newHttpChannel	back to summary
protected HttpChannelOverHTTP newHttpChannel()

onFillable	back to summary
public void onFillable() Implements abstract org.eclipse.jetty.io.AbstractConnection.onFillable. Doc from org.eclipse.jetty.io.AbstractConnection.onFillable. Callback method invoked when the endpoint is ready to be read. Annotations @Override

onFillable

back to summary

public void onFillable()

Implements abstract org.eclipse.jetty.io.AbstractConnection.onFillable.

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

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

Annotations

@Override

onIdleExpired	back to summary
public boolean onIdleExpired(TimeoutException timeout) Overrides org.eclipse.jetty.io.AbstractConnection.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. Returns:boolean true to let the EndPoint handle the idle timeout, false to tell the EndPoint to halt the handling of the idle timeout. Annotations @Override

onIdleExpired

back to summary

public boolean onIdleExpired(TimeoutException timeout)

Overrides org.eclipse.jetty.io.AbstractConnection.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.

Returns:boolean

true to let the EndPoint handle the idle timeout, false to tell the EndPoint to halt the handling of the idle timeout.

Annotations

@Override

onIdleTimeout	back to summary
protected boolean onIdleTimeout(long idleTimeout)

onOpen	back to summary
public void onOpen() Overrides org.eclipse.jetty.io.AbstractConnection.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

onOpen

back to summary

public void onOpen()

Overrides org.eclipse.jetty.io.AbstractConnection.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

onResponseHeaders	back to summary
pack-priv void onResponseHeaders(HttpExchange exchange)

onUpgradeFrom back to summary

onUpgradeFrom	back to summary
public ByteBuffer onUpgradeFrom() Implements org.eclipse.jetty.io.Connection.UpgradeFrom.onUpgradeFrom. Doc from org.eclipse.jetty.io.Connection.UpgradeFrom.onUpgradeFrom. Invoked during an `upgrade` to produce a buffer containing bytes that have not been consumed by this connection, and that must be consumed by the upgrade-to connection. Returns:ByteBuffer a buffer of unconsumed bytes to pass to the upgrade-to connection. The buffer does not belong to any pool and should be discarded after having consumed its bytes. The returned buffer may be null if there are no unconsumed bytes. Annotations @Override

public ByteBuffer onUpgradeFrom()

Implements org.eclipse.jetty.io.Connection.UpgradeFrom.onUpgradeFrom.

Doc from org.eclipse.jetty.io.Connection.UpgradeFrom.onUpgradeFrom.

Invoked during an upgrade to produce a buffer containing bytes that have not been consumed by this connection, and that must be consumed by the upgrade-to connection.

Returns:ByteBuffer

a buffer of unconsumed bytes to pass to the upgrade-to connection. The buffer does not belong to any pool and should be discarded after having consumed its bytes. The returned buffer may be null if there are no unconsumed bytes.

Annotations

@Override

promiseFrom	back to summary
private static Promise<Connection> promiseFrom(Map<String, Object> context) Annotations @SuppressWarnings:unchecked

release	back to summary
public void release()

remove	back to summary
public void remove()

send back to summary

send	back to summary
public void send(Request request, Response.CompleteListener listener) Implements org.eclipse.jetty.client.Connection.send. Doc from org.eclipse.jetty.client.Connection.send. Sends a request with an associated response listener. `Request#send(Response.CompleteListener)` will eventually call this method to send the request. It is exposed to allow applications to send requests via unpooled connections. Parameters request:Request the request to send listener:Response.CompleteListener the response listener Annotations @Override

public void send(Request request, Response.CompleteListener listener)

Implements org.eclipse.jetty.client.Connection.send.

Doc from org.eclipse.jetty.client.Connection.send.

Sends a request with an associated response listener.

Request#send(Response.CompleteListener) will eventually call this method to send the request. It is exposed to allow applications to send requests via unpooled connections.

Parameters

request:Request: the request to send
listener:Response.CompleteListener: the response listener

Annotations

@Override

send	back to summary
public SendFailure send(HttpExchange exchange) Implements org.eclipse.jetty.client.transport.IConnection.send. Annotations @Override

send

back to summary

public SendFailure send(HttpExchange exchange)

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

Annotations

@Override

setAttachment	back to summary
public void setAttachment(Object obj) Implements org.eclipse.jetty.util.Attachable.setAttachment. Doc from org.eclipse.jetty.util.Attachable.setAttachment. Attaches the given object to this stream for later retrieval. Parameters obj:Object the object to attach to this instance Annotations @Override

setAttachment

back to summary

public void setAttachment(Object obj)

Implements org.eclipse.jetty.util.Attachable.setAttachment.

Doc from org.eclipse.jetty.util.Attachable.setAttachment.

Attaches the given object to this stream for later retrieval.

Parameters

obj:Object: the object to attach to this instance

Annotations

@Override

sweep	back to summary
public boolean sweep() Implements org.eclipse.jetty.util.thread.Sweeper.Sweepable.sweep. Returns:boolean Doc from org.eclipse.jetty.util.thread.Sweeper.Sweepable.sweep. whether this resource should be swept Annotations @Override

sweep

back to summary

public boolean sweep()

Implements org.eclipse.jetty.util.thread.Sweeper.Sweepable.sweep.

Returns:boolean

Doc from org.eclipse.jetty.util.thread.Sweeper.Sweepable.sweep.

whether this resource should be swept

Annotations

@Override

toConnectionString	back to summary
public String toConnectionString() Overrides org.eclipse.jetty.io.AbstractConnection.toConnectionString. Annotations @Override

toConnectionString

back to summary

public String toConnectionString()

Overrides org.eclipse.jetty.io.AbstractConnection.toConnectionString.

Annotations

@Override

org.eclipse.jetty.client.transport.internal back to summary

private Class HttpConnectionOverHTTP.Delegate

Class Inheritance

extends HttpConnection

java.lang.Object
org.eclipse.jetty.client.transport.HttpConnection
org.eclipse.jetty.client.transport.internal.HttpConnectionOverHTTP.Delegate

Constructor Summary

Access	Constructor and Description
private	Delegate(HttpDestination destination)

Method Summary

Modifier and Type	Method and Description
public void	close() Implements org.eclipse.jetty.client.Connection.close. Closes this stream and releases any system resources associated with it.
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 SocketAddress	getRemoteSocketAddress() Overrides default org.eclipse.jetty.client.Connection.getRemoteSocketAddress.
public boolean	isClosed() Implements org.eclipse.jetty.client.Connection.isClosed.
protected void	normalizeRequest(HttpRequest request) Overrides org.eclipse.jetty.client.transport.HttpConnection.normalizeRequest.
public SendFailure	send(HttpExchange exchange) Implements org.eclipse.jetty.client.transport.IConnection.send.
public String	toString() Overrides org.eclipse.jetty.client.transport.HttpConnection.toString. Returns a string representation of the object.

Inherited from org.eclipse.jetty.client.transport.HttpConnection:: destroy getAttachment getHttpClient getHttpDestination onIdleTimeout send send setAttachment

Constructor Detail

Delegate	back to summary
private Delegate(HttpDestination destination)

Method Detail

close back to summary

close	back 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

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.

Annotations