Package org.apache.sshd.server.forward
Class TcpipServerChannel
java.lang.Object
- All Implemented Interfaces:
Closeable
,AutoCloseable
,Channel
,AttributeRepository
,AttributeStore
,Channel
,ChannelListenerManager
,StreamingChannel
,ChannelStreamWriterResolver
,ChannelStreamWriterResolverManager
,Closeable
,ForwardingTunnelEndpointsProvider
,PropertyResolver
,SessionContextHolder
,SessionHolder<Session>
,ExecutorServiceCarrier
,ServerChannel
,ServerSessionHolder
public class TcpipServerChannel
extends AbstractServerChannel
implements StreamingChannel, ForwardingTunnelEndpointsProvider
TODO Add javadoc
-
Nested Class Summary
Nested ClassesNested classes/interfaces inherited from class org.apache.sshd.common.channel.AbstractChannel
AbstractChannel.GracefulChannelCloseable, AbstractChannel.GracefulState
Nested classes/interfaces inherited from class org.apache.sshd.common.util.closeable.AbstractCloseable
AbstractCloseable.State
Nested classes/interfaces inherited from interface org.apache.sshd.common.AttributeRepository
AttributeRepository.AttributeKey<T>
Nested classes/interfaces inherited from interface org.apache.sshd.common.channel.StreamingChannel
StreamingChannel.Streaming
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate IoConnector
private final AtomicLong
private IoSession
private SocketAddress
private SshdSocketAddress
private IoOutputStream
private StreamingChannel.Streaming
private SshdSocketAddress
private SshdSocketAddress
private final TcpForwardingFilter.Type
Fields inherited from class org.apache.sshd.server.channel.AbstractServerChannel
exitStatusSent
Fields inherited from class org.apache.sshd.common.channel.AbstractChannel
channelListenerProxy, channelListeners, eofReceived, eofSent, gracefulFuture, gracefulState, initialized, RESPONSE_BUFFER_GROWTH_FACTOR, service
Fields inherited from class org.apache.sshd.common.util.closeable.AbstractCloseable
closeFuture, futureLock, state
Fields inherited from class org.apache.sshd.common.util.logging.AbstractLoggingBean
log
Fields inherited from interface org.apache.sshd.common.channel.Channel
CHANNEL_EXEC, CHANNEL_SHELL, CHANNEL_SUBSYSTEM
Fields inherited from interface org.apache.sshd.common.channel.throttle.ChannelStreamWriterResolver
NONE
Fields inherited from interface org.apache.sshd.common.PropertyResolver
EMPTY
-
Constructor Summary
ConstructorsConstructorDescriptionTcpipServerChannel
(TcpForwardingFilter.Type type, CloseableExecutorService executor) -
Method Summary
Modifier and TypeMethodDescriptionprotected OpenFuture
protected void
doWriteData
(byte[] data, int off, long len) protected void
doWriteExtendedData
(byte[] data, int off, long len) protected Closeable
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) void
setStreaming
(StreamingChannel.Streaming streaming) Methods inherited from class org.apache.sshd.server.channel.AbstractServerChannel
handleOpenFailure, handleOpenSuccess, open, sendExitStatus
Methods inherited from class org.apache.sshd.common.channel.AbstractChannel
addChannelListener, addPendingRequest, addRequestHandler, attributeKeys, clearAttributes, computeAttributeIfAbsent, configureWindow, getAttribute, getAttributesCount, getChannelListenerProxy, getChannelStreamWriterResolver, 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, resolveChannelStreamWriterResolver, sendEof, sendResponse, sendWindowAdjust, setAttribute, setChannelStreamWriterResolver, setRecipient, signalChannelClosed, signalChannelClosed, signalChannelInitialized, signalChannelInitialized, signalChannelOpenFailure, signalChannelOpenFailure, signalChannelOpenSuccess, signalChannelOpenSuccess, toString, validateIncomingDataSize, writePacket
Methods inherited from class org.apache.sshd.common.util.closeable.AbstractInnerCloseable
doCloseGracefully, doCloseImmediately
Methods inherited from class org.apache.sshd.common.util.closeable.AbstractCloseable
addCloseFutureListener, builder, close, getFutureLock, isClosed, isClosing, removeCloseFutureListener
Methods inherited from class org.apache.sshd.common.util.logging.AbstractLoggingBean
debug, debug, debug, debug, debug, error, error, error, error, error, getSimplifiedLogger, info, info, warn, warn, warn, warn, warn, warn, warn, warn
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface org.apache.sshd.common.AttributeRepository
attributeKeys, getAttribute, getAttributesCount
Methods inherited from interface org.apache.sshd.common.AttributeStore
clearAttributes, computeAttributeIfAbsent, removeAttribute, setAttribute
Methods inherited from interface org.apache.sshd.common.channel.Channel
addRequestHandler, addRequestHandlers, getId, getLocalWindow, getRecipient, getRemoteWindow, getRequestHandlers, handleClose, handleData, handleEof, handleExtendedData, handleFailure, handleRequest, handleSuccess, handleWindowAdjust, init, isEofSignalled, isInitialized, removeRequestHandler, removeRequestHandlers, resolveAttribute, writePacket
Methods inherited from interface org.apache.sshd.common.channel.ChannelListenerManager
addChannelListener, getChannelListenerProxy, removeChannelListener
Methods inherited from interface org.apache.sshd.common.channel.throttle.ChannelStreamWriterResolverManager
getChannelStreamWriterResolver, resolveChannelStreamWriter, resolveChannelStreamWriterResolver, setChannelStreamWriterResolver
Methods inherited from interface org.apache.sshd.common.Closeable
addCloseFutureListener, close, close, isClosed, isClosing, isOpen, removeCloseFutureListener
Methods inherited from interface org.apache.sshd.common.PropertyResolver
getBoolean, getBooleanProperty, getCharset, getInteger, getIntProperty, getLong, getLongProperty, getObject, getParentPropertyResolver, getProperties, getString, getStringProperty
Methods inherited from interface org.apache.sshd.server.channel.ServerChannel
getServerSession
Methods inherited from interface org.apache.sshd.common.session.SessionHolder
getSession, getSessionContext
-
Field Details
-
type
-
connector
-
ioSession
-
out
-
tunnelEntrance
-
tunnelExit
-
originatorAddress
-
localAddress
-
inFlightDataSize
-
streaming
-
-
Constructor Details
-
TcpipServerChannel
-
-
Method Details
-
getTcpipChannelType
-
getLocalAddress
-
setLocalAddress
-
getStreaming
- Specified by:
getStreaming
in interfaceStreamingChannel
-
setStreaming
- Specified by:
setStreaming
in interfaceStreamingChannel
-
getTunnelEntrance
- Specified by:
getTunnelEntrance
in interfaceForwardingTunnelEndpointsProvider
-
getTunnelExit
- Specified by:
getTunnelExit
in interfaceForwardingTunnelEndpointsProvider
-
getOriginatorAddress
-
getIoSession
-
doInit
- Overrides:
doInit
in classAbstractServerChannel
-
handleChannelConnectResult
-
handleChannelOpenSuccess
-
handleChannelOpenFailure
-
getInnerCloseable
- Overrides:
getInnerCloseable
in classAbstractChannel
-
doWriteData
- Specified by:
doWriteData
in classAbstractChannel
- Throws:
IOException
-
doWriteExtendedData
- Specified by:
doWriteExtendedData
in classAbstractChannel
- Throws:
IOException
-
handleWriteDataSuccess
protected void handleWriteDataSuccess(byte cmd, byte[] data, int off, int len) -
handleWriteDataFailure
-