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

Class HttpConnectionOverHTTP

java.lang.Object

org.eclipse.jetty.io.AbstractConnection

org.eclipse.jetty.client.transport.internal.HttpConnectionOverHTTP

All Implemented Interfaces:

Closeable, AutoCloseable, Connection, IConnection, Connection, Connection.UpgradeFrom, Attachable, Invocable, Sweeper.Sweepable

public class HttpConnectionOverHTTP
extends AbstractConnection
implements IConnection, Connection.UpgradeFrom, Sweeper.Sweepable, Attachable

Nested Class Summary

Nested classes/interfaces inherited from interface org.eclipse.jetty.io.Connection

Connection.Listener, Connection.UpgradeFrom, Connection.UpgradeTo

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.thread.Invocable

Invocable.Callable, Invocable.InvocationType, Invocable.ReadyTask, Invocable.Task

Field Summary

Fields inherited from interface org.eclipse.jetty.util.thread.Invocable

__nonBlocking, NOOP

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected void	abort(Throwable failure, Promise<Boolean> promise)
protected void	addBytesIn(long bytesIn)
protected void	addBytesOut(long bytesOut)
void	close()	Performs a logical close of this connection.
protected void	close(Throwable failure)
Object	getAttachment()
long	getBytesIn()
long	getBytesOut()
HttpChannelOverHTTP	getHttpChannel()
HttpDestination	getHttpDestination()
SocketAddress	getLocalSocketAddress()
long	getMessagesIn()
long	getMessagesOut()
SocketAddress	getRemoteSocketAddress()
EndPoint.SslSessionData	getSslSessionData()
boolean	isClosed()
boolean	isInitialize()
protected HttpChannelOverHTTP	newHttpChannel()
void	onFillable()	Callback method invoked when the endpoint is ready to be read.
boolean	onIdleExpired(TimeoutException timeout)	Callback method invoked upon an idle timeout event.
protected boolean	onIdleTimeout(long idleTimeout)
void	onOpen()	Callback method invoked when this connection is opened.
ByteBuffer	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.
void	release()
void	remove()
void	send(Request request, Response.CompleteListener listener)	Sends a request with an associated response listener.
SendFailure	send(HttpExchange exchange)
void	setAttachment(Object obj)	Attaches the given object to this stream for later retrieval.
void	setInitialize(boolean initialize)
boolean	sweep()
String	toConnectionString()

Methods inherited from class org.eclipse.jetty.io.AbstractConnection

addEventListener, failedCallback, fillInterested, getCreatedTimeStamp, getEndPoint, getExecutor, getInputBufferSize, getInvocationType, isFillInterested, onClose, onFillInterestedFailed, onReadTimeout, removeEventListener, setInputBufferSize, toString, tryFillInterested

Methods inherited from class java.lang.Object

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

Constructor Details

HttpConnectionOverHTTP

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

HttpConnectionOverHTTP

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

Method Details

newHttpChannel

protected HttpChannelOverHTTP newHttpChannel()

getHttpChannel

public HttpChannelOverHTTP getHttpChannel()

getHttpDestination

public HttpDestination getHttpDestination()

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

getSslSessionData

public EndPoint.SslSessionData getSslSessionData()

Specified by:

getSslSessionData in interface Connection

Returns:

the EndPoint.SslSessionData associated with the connection, or null if the connection is not secure.

getBytesIn

public long getBytesIn()

Specified by:

getBytesIn in interface Connection

Overrides:

getBytesIn in class AbstractConnection

addBytesIn

protected void addBytesIn(long bytesIn)

getBytesOut

public long getBytesOut()

Specified by:

getBytesOut in interface Connection

Overrides:

getBytesOut in class AbstractConnection

addBytesOut

protected void addBytesOut(long bytesOut)

getMessagesIn

public long getMessagesIn()

Specified by:

getMessagesIn in interface Connection

Overrides:

getMessagesIn in class AbstractConnection

getMessagesOut

public long getMessagesOut()

Specified by:

getMessagesOut in interface Connection

Overrides:

getMessagesOut in class AbstractConnection

send

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

Description copied from interface: Connection

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.

Specified by:

send in interface Connection

Parameters:

request - the request to send

listener - the response listener

send

public SendFailure send(HttpExchange exchange)

Specified by:

send in interface IConnection

isInitialize

public boolean isInitialize()

Returns:

whether to initialize the connection with an OPTIONS * HTTP/1.1 request.

setInitialize

public void setInitialize(boolean initialize)

Parameters:

initialize - whether to initialize the connection with an OPTIONS * HTTP/1.1 request.

onOpen

public void onOpen()

Description copied from interface: Connection

Callback method invoked when this connection is opened.

Creators of the connection implementation are responsible for calling this method.

Specified by:

onOpen in interface Connection

Overrides:

onOpen in class AbstractConnection

isClosed

public boolean isClosed()

Specified by:

isClosed in interface Connection

Returns:

whether this connection has been closed

See Also:

• Connection.close()

setAttachment

public void setAttachment(Object obj)

Description copied from interface: Attachable

Attaches the given object to this stream for later retrieval.

Specified by:

setAttachment in interface Attachable

Parameters:

obj - the object to attach to this instance

getAttachment

public Object getAttachment()

Specified by:

getAttachment in interface Attachable

Returns:

the object attached to this instance

See Also:

• Attachable.setAttachment(Object)

onIdleExpired

public boolean onIdleExpired(TimeoutException timeout)

Description copied from interface: Connection

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.

Specified by:

onIdleExpired in interface Connection

Overrides:

onIdleExpired in class AbstractConnection

Returns:

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

onIdleTimeout

protected boolean onIdleTimeout(long idleTimeout)

onFillable

public void onFillable()

Description copied from class: AbstractConnection

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

Specified by:

onFillable in class AbstractConnection

See Also:

• AbstractConnection.fillInterested()

onUpgradeFrom

public ByteBuffer onUpgradeFrom()

Description copied from interface: Connection.UpgradeFrom

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.

Specified by:

onUpgradeFrom in interface Connection.UpgradeFrom

Returns:

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.

release

public void release()

remove

public void remove()

close

public void close()

Description copied from interface: Connection

Performs a logical close of this connection.

For simple connections, this may just mean to delegate the close to the associated EndPoint but, for example, SSL connections should write the SSL close message before closing the associated EndPoint.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Connection

Specified by:

close in interface Connection

Overrides:

close in class AbstractConnection

close

protected void close(Throwable failure)

abort

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

sweep

public boolean sweep()

Specified by:

sweep in interface Sweeper.Sweepable

Returns:

whether this resource should be swept

toConnectionString

public String toConnectionString()

Overrides:

toConnectionString in class AbstractConnection