Package org.eclipse.jetty.proxy

Class ProxyConnection

java.lang.Object

org.eclipse.jetty.io.AbstractConnection

org.eclipse.jetty.proxy.ProxyConnection

All Implemented Interfaces:

Closeable, AutoCloseable, Connection

Direct Known Subclasses:

ConnectHandler.DownstreamConnection, ConnectHandler.UpstreamConnection

public abstract class ProxyConnection
extends AbstractConnection

Nested Class Summary

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

Connection.Listener, Connection.UpgradeFrom, Connection.UpgradeTo

Field Summary

Fields

Modifier and Type	Field	Description
protected static final org.slf4j.Logger	LOG

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ProxyConnection(EndPoint endp, Executor executor, ByteBufferPool bufferPool, ConcurrentMap<String,Object> context)

Method Summary

Modifier and Type	Method	Description
protected void	close(Throwable failure)
ByteBufferPool	getByteBufferPool()
Connection	getConnection()
ConcurrentMap<String,Object>	getContext()
void	onFillable()	Callback method invoked when the endpoint is ready to be read.
protected abstract int	read(EndPoint endPoint, ByteBuffer buffer)
void	setConnection(ProxyConnection connection)
String	toConnectionString()
protected abstract void	write(EndPoint endPoint, ByteBuffer buffer, Callback callback)

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

addEventListener, close, failedCallback, fillInterested, getBytesIn, getBytesOut, getCreatedTimeStamp, getEndPoint, getExecutor, getInputBufferSize, getMessagesIn, getMessagesOut, isFillInterested, onClose, onFillInterestedFailed, onIdleExpired, onOpen, onReadTimeout, removeEventListener, setInputBufferSize, toString, tryFillInterested

Methods inherited from class java.lang.Object

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

Field Details

LOG

protected static final org.slf4j.Logger LOG

Constructor Details

ProxyConnection

protected ProxyConnection(EndPoint endp,
 Executor executor,
 ByteBufferPool bufferPool,
 ConcurrentMap<String,Object> context)

Method Details

getByteBufferPool

public ByteBufferPool getByteBufferPool()

getContext

public ConcurrentMap<String,Object> getContext()

getConnection

public Connection getConnection()

setConnection

public void setConnection(ProxyConnection connection)

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()

read

protected abstract int read(EndPoint endPoint,
 ByteBuffer buffer)
                     throws IOException

Throws:

IOException

write

protected abstract void write(EndPoint endPoint,
 ByteBuffer buffer,
 Callback callback)

close

protected void close(Throwable failure)

toConnectionString

public String toConnectionString()

Overrides:

toConnectionString in class AbstractConnection