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>
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,
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() |
SocketAddress |
getLocalAddress() |
SshdSocketAddress |
getOriginatorAddress() |
TcpForwardingFilter.Type |
getTcpipChannelType() |
SshdSocketAddress |
getTunnelEntrance() |
SshdSocketAddress |
getTunnelExit() |
protected void |
handleChannelConnectResult(OpenFuture f,
IoConnectFuture future) |
protected void |
handleChannelOpenFailure(OpenFuture f,
Throwable problem) |
protected void |
handleChannelOpenSuccess(OpenFuture f,
IoSession session) |
protected void |
handleWriteDataFailure(byte cmd,
byte[] data,
int off,
int len,
Throwable t) |
protected void |
handleWriteDataSuccess(byte cmd,
byte[] data,
int off,
int len) |
void |
setLocalAddress(SocketAddress localAddress) |
getServerSession, 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, 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, resolveAttribute, resolveAttribute
addChannelListener, getChannelListenerProxy, removeChannelListener
getBoolean, getBooleanProperty, getInteger, getIntProperty, getLong, getLongProperty, getObject, getParentPropertyResolver, getProperties, getString, getStringProperty
clearAttributes, computeAttributeIfAbsent, removeAttribute, setAttribute
attributeKeys, getAttribute, getAttributesCount, ofAttributesMap, ofKeyValuePair
writePacket
getChannelStreamPacketWriterResolver, resolveChannelStreamPacketWriter, resolveChannelStreamPacketWriterResolver, setChannelStreamPacketWriterResolver
addCloseFutureListener, close, close, close, getMaxCloseWaitTime, isClosed, isClosing, isOpen, removeCloseFutureListener
public TcpipServerChannel(TcpForwardingFilter.Type type, CloseableExecutorService executor)
public TcpForwardingFilter.Type getTcpipChannelType()
public SocketAddress getLocalAddress()
public void setLocalAddress(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, Throwable problem)
protected Closeable getInnerCloseable()
getInnerCloseable
in class AbstractChannel
protected void doWriteData(byte[] data, int off, long len) throws IOException
doWriteData
in class AbstractChannel
IOException
protected void doWriteExtendedData(byte[] data, int off, long len) throws IOException
doWriteExtendedData
in class AbstractChannel
IOException
protected void handleWriteDataSuccess(byte cmd, byte[] data, int off, int len)
protected void handleWriteDataFailure(byte cmd, byte[] data, int off, int len, Throwable t)
Copyright © 2008–2022 The Apache Software Foundation. All rights reserved.