Package org.eclipse.jetty.proxy
Class ConnectHandler.UpstreamConnection
- java.lang.Object
-
- org.eclipse.jetty.io.AbstractConnection
-
- org.eclipse.jetty.proxy.ProxyConnection
-
- org.eclipse.jetty.proxy.ConnectHandler.UpstreamConnection
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,Connection
- Enclosing class:
- ConnectHandler
public class ConnectHandler.UpstreamConnection extends ProxyConnection
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.eclipse.jetty.io.Connection
Connection.Listener, Connection.UpgradeFrom, Connection.UpgradeTo
-
-
Field Summary
-
Fields inherited from class org.eclipse.jetty.proxy.ProxyConnection
LOG
-
-
Constructor Summary
Constructors Constructor Description UpstreamConnection(EndPoint endPoint, java.util.concurrent.Executor executor, ByteBufferPool bufferPool, ConnectHandler.ConnectContext connectContext)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onOpen()
Callback method invoked when this connection is opened.protected int
read(EndPoint endPoint, java.nio.ByteBuffer buffer)
protected void
write(EndPoint endPoint, java.nio.ByteBuffer buffer, Callback callback)
-
Methods inherited from class org.eclipse.jetty.proxy.ProxyConnection
getByteBufferPool, getConnection, getContext, onFillable, setConnection, toConnectionString
-
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, onReadTimeout, removeListener, setInputBufferSize, toString, tryFillInterested, tryFillInterested
-
-
-
-
Constructor Detail
-
UpstreamConnection
public UpstreamConnection(EndPoint endPoint, java.util.concurrent.Executor executor, ByteBufferPool bufferPool, ConnectHandler.ConnectContext connectContext)
-
-
Method Detail
-
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 interfaceConnection
- Overrides:
onOpen
in classAbstractConnection
-
read
protected int read(EndPoint endPoint, java.nio.ByteBuffer buffer) throws java.io.IOException
- Specified by:
read
in classProxyConnection
- Throws:
java.io.IOException
-
write
protected void write(EndPoint endPoint, java.nio.ByteBuffer buffer, Callback callback)
- Specified by:
write
in classProxyConnection
-
-