public class TcpipServerChannel extends AbstractServerChannel
Modifier and Type | Class and Description |
---|---|
static class |
TcpipServerChannel.TcpipFactory |
AbstractChannel.GracefulChannelCloseable, AbstractChannel.GracefulState
AbstractCloseable.State
AttributeStore.AttributeKey<T>
Modifier and Type | Field and Description |
---|---|
private IoConnector |
connector |
private IoSession |
ioSession |
private java.io.OutputStream |
out |
private TcpForwardingFilter.Type |
type |
exitStatusSent
channelListenerProxy, channelListeners, eofReceived, eofSent, gracefulFuture, gracefulState, initialized, RESPONSE_BUFFER_GROWTH_FACTOR, service
closeFuture, lock, state
log
CHANNEL_EXEC, CHANNEL_SHELL, CHANNEL_SUBSYSTEM
EMPTY
NONE
CLOSE_WAIT_TIMEOUT, DEFAULT_CLOSE_WAIT_TIMEOUT
Constructor and Description |
---|
TcpipServerChannel(TcpForwardingFilter.Type type) |
Modifier and Type | Method and Description |
---|---|
CloseFuture |
close(boolean immediately)
Close this resource asynchronously and return a future.
|
protected OpenFuture |
doInit(Buffer buffer) |
protected void |
doWriteData(byte[] data,
int off,
long len) |
protected void |
doWriteExtendedData(byte[] data,
int off,
long len) |
TcpForwardingFilter.Type |
getTcpipChannelType() |
protected void |
handleChannelConnectResult(OpenFuture f,
IoConnectFuture future) |
protected void |
handleChannelOpenFailure(OpenFuture f,
java.lang.Throwable problem) |
protected void |
handleChannelOpenSuccess(OpenFuture f,
IoSession session) |
protected void |
handleWriteDataFailure(byte cmd,
byte[] data,
int off,
int len,
java.lang.Throwable t) |
protected void |
handleWriteDataSuccess(byte cmd,
byte[] data,
int off,
int len) |
getServerSession, handleOpenFailure, handleOpenSuccess, open, sendExitStatus
addChannelListener, addPendingRequest, addRequestHandler, configureWindow, doCloseImmediately, getAttribute, getChannelListenerProxy, getChannelStreamPacketWriterResolver, getExecutorService, getId, getInnerCloseable, getLocalWindow, getParentPropertyResolver, getProperties, getRecipient, getRemoteWindow, getRequestHandlers, getSession, handleChannelRequest, handleClose, handleData, handleEof, handleExtendedData, handleFailure, handleInternalRequest, handleRequest, handleSuccess, handleUnknownChannelRequest, handleWindowAdjust, init, invokeChannelSignaller, isEofSent, isEofSignalled, isInitialized, isShutdownOnExit, notifyStateChanged, notifyStateChanged, preClose, removeAttribute, removeChannelListener, removePendingRequest, removeRequestHandler, resolveAttribute, resolveChannelStreamPacketWriterResolver, sendEof, sendResponse, sendWindowAdjust, setAttribute, setChannelStreamPacketWriterResolver, setExecutorService, setRecipient, setShutdownOnExit, signalChannelClosed, signalChannelClosed, signalChannelInitialized, signalChannelInitialized, signalChannelOpenFailure, signalChannelOpenFailure, signalChannelOpenSuccess, signalChannelOpenSuccess, toString, validateIncomingDataSize, writePacket
doCloseGracefully
addCloseFutureListener, builder, isClosed, isClosing, removeCloseFutureListener
getSimplifiedLogger
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addRequestHandler, addRequestHandlers, getId, getLocalWindow, getRecipient, getRemoteWindow, getRequestHandlers, getSession, handleClose, handleData, handleEof, handleExtendedData, handleFailure, handleRequest, handleSuccess, handleWindowAdjust, init, isEofSignalled, isInitialized, removeRequestHandler, removeRequestHandlers
addChannelListener, getChannelListenerProxy, removeChannelListener
getBoolean, getBooleanProperty, getInteger, getIntProperty, getLong, getLongProperty, getObject, getParentPropertyResolver, getProperties, getString, getStringProperty
getAttribute, removeAttribute, resolveAttribute, resolveAttribute, resolveAttribute, resolveAttribute, setAttribute
writePacket
getChannelStreamPacketWriterResolver, resolveChannelStreamPacketWriter, resolveChannelStreamPacketWriterResolver, setChannelStreamPacketWriterResolver
addCloseFutureListener, close, close, getMaxCloseWaitTime, isClosed, isClosing, isOpen, removeCloseFutureListener
private final TcpForwardingFilter.Type type
private IoConnector connector
private IoSession ioSession
private java.io.OutputStream out
public TcpipServerChannel(TcpForwardingFilter.Type type)
public TcpForwardingFilter.Type getTcpipChannelType()
protected OpenFuture doInit(Buffer buffer)
doInit
in class AbstractServerChannel
protected void handleChannelConnectResult(OpenFuture f, IoConnectFuture future)
protected void handleChannelOpenSuccess(OpenFuture f, IoSession session)
protected void handleChannelOpenFailure(OpenFuture f, java.lang.Throwable problem)
public CloseFuture close(boolean immediately)
Closeable
close
in class AbstractChannel
immediately
- true
if the resource should be shut down abruptly,
false
for a graceful closeCloseFuture
representing the close requestprotected void doWriteData(byte[] data, int off, long len) throws java.io.IOException
doWriteData
in class AbstractChannel
java.io.IOException
protected void doWriteExtendedData(byte[] data, int off, long len) throws java.io.IOException
doWriteExtendedData
in class AbstractChannel
java.io.IOException
protected void handleWriteDataSuccess(byte cmd, byte[] data, int off, int len)
protected void handleWriteDataFailure(byte cmd, byte[] data, int off, int len, java.lang.Throwable t)