public class TcpipServerChannel extends AbstractServerChannel implements ForwardingTunnelEndpointsProvider
Modifier and Type | Class and Description |
---|---|
static class |
TcpipServerChannel.TcpipFactory |
AbstractChannel.GracefulChannelCloseable, AbstractChannel.GracefulState
AbstractCloseable.State
AttributeRepository.AttributeKey<T>
Modifier and Type | Field and Description |
---|---|
private IoConnector |
connector |
private IoSession |
ioSession |
private java.net.SocketAddress |
localAddress |
private SshdSocketAddress |
originatorAddress |
private IoOutputStream |
out |
private SshdSocketAddress |
tunnelEntrance |
private SshdSocketAddress |
tunnelExit |
private TcpForwardingFilter.Type |
type |
exitStatusSent
channelListenerProxy, channelListeners, eofReceived, eofSent, gracefulFuture, gracefulState, initialized, RESPONSE_BUFFER_GROWTH_FACTOR, service
closeFuture, futureLock, state
log
CHANNEL_EXEC, CHANNEL_SHELL, CHANNEL_SUBSYSTEM
EMPTY
NONE
CLOSE_WAIT_TIMEOUT, DEFAULT_CLOSE_WAIT_TIMEOUT
Constructor and Description |
---|
TcpipServerChannel(TcpForwardingFilter.Type type,
CloseableExecutorService executor) |
Modifier and Type | Method and Description |
---|---|
protected OpenFuture |
doInit(Buffer buffer) |
protected void |
doWriteData(byte[] data,
int off,
long len) |
protected void |
doWriteExtendedData(byte[] data,
int off,
long len) |
protected Closeable |
getInnerCloseable() |
IoSession |
getIoSession() |
java.net.SocketAddress |
getLocalAddress() |
SshdSocketAddress |
getOriginatorAddress() |
TcpForwardingFilter.Type |
getTcpipChannelType() |
SshdSocketAddress |
getTunnelEntrance() |
SshdSocketAddress |
getTunnelExit() |
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) |
void |
setLocalAddress(java.net.SocketAddress localAddress) |
handleOpenFailure, handleOpenSuccess, open, sendExitStatus
addChannelListener, addPendingRequest, addRequestHandler, attributeKeys, clearAttributes, computeAttributeIfAbsent, configureWindow, getAttribute, getAttributesCount, getChannelListenerProxy, getChannelStreamPacketWriterResolver, getExecutorService, getId, getLocalWindow, getParentPropertyResolver, getProperties, getRecipient, getRemoteWindow, getRequestHandlers, getSession, handleChannelRequest, handleClose, handleData, handleEof, handleExtendedData, handleFailure, handleInternalRequest, handleRequest, handleSuccess, handleUnknownChannelRequest, handleWindowAdjust, init, invokeChannelSignaller, isEofSent, isEofSignalled, isInitialized, notifyStateChanged, notifyStateChanged, preClose, removeAttribute, removeChannelListener, removePendingRequest, removeRequestHandler, resolveChannelStreamPacketWriterResolver, sendEof, sendResponse, sendWindowAdjust, setAttribute, setChannelStreamPacketWriterResolver, setRecipient, signalChannelClosed, signalChannelClosed, signalChannelInitialized, signalChannelInitialized, signalChannelOpenFailure, signalChannelOpenFailure, signalChannelOpenSuccess, signalChannelOpenSuccess, toString, validateIncomingDataSize, writePacket
doCloseGracefully, doCloseImmediately
addCloseFutureListener, builder, close, getFutureLock, isClosed, isClosing, removeCloseFutureListener
getSimplifiedLogger
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getServerSession
addRequestHandler, addRequestHandlers, getId, getLocalWindow, getRecipient, getRemoteWindow, getRequestHandlers, handleClose, handleData, handleEof, handleExtendedData, handleFailure, handleRequest, handleSuccess, handleWindowAdjust, init, isEofSignalled, isInitialized, removeRequestHandler, removeRequestHandlers, resolveAttribute, resolveAttribute
getSession, getSessionContext
addChannelListener, getChannelListenerProxy, removeChannelListener
getBoolean, getBooleanProperty, getCharset, getInteger, getIntProperty, getLong, getLongProperty, getObject, getParentPropertyResolver, getProperties, getString, getStringProperty
clearAttributes, computeAttributeIfAbsent, removeAttribute, setAttribute
attributeKeys, getAttribute, getAttributesCount, ofAttributesMap, ofKeyValuePair
calculatePadLength, writePacket
getChannelStreamPacketWriterResolver, resolveChannelStreamPacketWriter, resolveChannelStreamPacketWriterResolver, setChannelStreamPacketWriterResolver
addCloseFutureListener, close, close, close, getMaxCloseWaitTime, isClosed, isClosing, isOpen, removeCloseFutureListener
private final TcpForwardingFilter.Type type
private IoConnector connector
private IoSession ioSession
private IoOutputStream out
private SshdSocketAddress tunnelEntrance
private SshdSocketAddress tunnelExit
private SshdSocketAddress originatorAddress
private java.net.SocketAddress localAddress
public TcpipServerChannel(TcpForwardingFilter.Type type, CloseableExecutorService executor)
public TcpForwardingFilter.Type getTcpipChannelType()
public java.net.SocketAddress getLocalAddress()
public void setLocalAddress(java.net.SocketAddress localAddress)
public SshdSocketAddress getTunnelEntrance()
getTunnelEntrance
in interface ForwardingTunnelEndpointsProvider
public SshdSocketAddress getTunnelExit()
getTunnelExit
in interface ForwardingTunnelEndpointsProvider
public SshdSocketAddress getOriginatorAddress()
public IoSession getIoSession()
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)
protected Closeable getInnerCloseable()
getInnerCloseable
in class AbstractChannel
protected 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)