Package org.eclipse.jetty.proxy
Class ProxyConnection
- java.lang.Object
-
- org.eclipse.jetty.io.AbstractConnection
-
- org.eclipse.jetty.proxy.ProxyConnection
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.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 org.eclipse.jetty.io.Connection
Connection.Listener, Connection.UpgradeFrom, Connection.UpgradeTo
-
-
Field Summary
Fields Modifier and Type Field Description private ByteBufferPool
bufferPool
private Connection
connection
private java.util.concurrent.ConcurrentMap<java.lang.String,java.lang.Object>
context
protected static Logger
LOG
private IteratingCallback
pipe
-
Constructor Summary
Constructors Modifier Constructor Description protected
ProxyConnection(EndPoint endp, java.util.concurrent.Executor executor, ByteBufferPool bufferPool, java.util.concurrent.ConcurrentMap<java.lang.String,java.lang.Object> context)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description ByteBufferPool
getByteBufferPool()
Connection
getConnection()
java.util.concurrent.ConcurrentMap<java.lang.String,java.lang.Object>
getContext()
void
onFillable()
Callback method invoked when the endpoint is ready to be read.protected abstract int
read(EndPoint endPoint, java.nio.ByteBuffer buffer)
void
setConnection(Connection connection)
java.lang.String
toConnectionString()
protected abstract void
write(EndPoint endPoint, java.nio.ByteBuffer buffer, Callback callback)
-
Methods inherited from class org.eclipse.jetty.io.AbstractConnection
addListener, close, failedCallback, fillInterested, getBytesIn, getBytesOut, getCreatedTimeStamp, getEndPoint, getExecutor, getInputBufferSize, getMessagesIn, getMessagesOut, isFillInterested, onClose, onFillInterestedFailed, onIdleExpired, onOpen, onReadTimeout, removeListener, setInputBufferSize, toString, tryFillInterested, tryFillInterested
-
-
-
-
Field Detail
-
LOG
protected static final Logger LOG
-
pipe
private final IteratingCallback pipe
-
bufferPool
private final ByteBufferPool bufferPool
-
context
private final java.util.concurrent.ConcurrentMap<java.lang.String,java.lang.Object> context
-
connection
private Connection connection
-
-
Constructor Detail
-
ProxyConnection
protected ProxyConnection(EndPoint endp, java.util.concurrent.Executor executor, ByteBufferPool bufferPool, java.util.concurrent.ConcurrentMap<java.lang.String,java.lang.Object> context)
-
-
Method Detail
-
getByteBufferPool
public ByteBufferPool getByteBufferPool()
-
getContext
public java.util.concurrent.ConcurrentMap<java.lang.String,java.lang.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 classAbstractConnection
- See Also:
AbstractConnection.fillInterested()
-
read
protected abstract int read(EndPoint endPoint, java.nio.ByteBuffer buffer) throws java.io.IOException
- Throws:
java.io.IOException
-
write
protected abstract void write(EndPoint endPoint, java.nio.ByteBuffer buffer, Callback callback)
-
toConnectionString
public java.lang.String toConnectionString()
- Overrides:
toConnectionString
in classAbstractConnection
-
-