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

Modifier and Type	Class	Description
private class	ProxyConnection.ProxyIteratingCallback

Nested classes/interfaces inherited from interface Connection

Connection.Listener, Connection.UpgradeFrom, Connection.UpgradeTo

Field Summary

Fields

Modifier and Type	Field	Description
private final ByteBufferPool	bufferPool
private Connection	connection
private final ConcurrentMap<String,Object>	context
protected static final Logger	LOG
private final IteratingCallback	pipe

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
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(Connection connection)
String	toConnectionString()
protected abstract void	write(EndPoint endPoint, ByteBuffer buffer, Callback callback)

Methods inherited from class AbstractConnection

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

Methods inherited from class Object

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

Field Details

LOG

protected static final Logger LOG

pipe

private final IteratingCallback pipe

bufferPool

private final ByteBufferPool bufferPool

context

private final ConcurrentMap<String,Object> context

connection

private Connection connection

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

toConnectionString

public String toConnectionString()

Overrides:

toConnectionString in class AbstractConnection