Package org.apache.sshd.server.forward
Class TcpipServerChannel
- java.lang.Object
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,java.nio.channels.Channel
,AttributeRepository
,AttributeStore
,Channel
,ChannelListenerManager
,ChannelStreamPacketWriterResolver
,ChannelStreamPacketWriterResolverManager
,Closeable
,ForwardingTunnelEndpointsProvider
,PacketWriter
,PropertyResolver
,SessionContextHolder
,SessionHolder<Session>
,ExecutorServiceCarrier
,ServerChannel
,ServerSessionHolder
public class TcpipServerChannel extends AbstractServerChannel implements ForwardingTunnelEndpointsProvider
TODO Add javadoc
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
TcpipServerChannel.TcpipFactory
-
Nested 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>
-
-
Field Summary
Fields Modifier and Type Field Description private IoConnector
connector
private IoSession
ioSession
private java.net.SocketAddress
localAddress
private SshdSocketAddress
originatorAddress
private java.io.OutputStream
out
private SshdSocketAddress
tunnelEntrance
private SshdSocketAddress
tunnelExit
private TcpForwardingFilter.Type
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.ChannelStreamPacketWriterResolver
NONE
-
Fields inherited from interface org.apache.sshd.common.Closeable
CLOSE_WAIT_TIMEOUT, DEFAULT_CLOSE_WAIT_TIMEOUT
-
Fields inherited from interface org.apache.sshd.common.PropertyResolver
EMPTY
-
-
Constructor Summary
Constructors Constructor Description TcpipServerChannel(TcpForwardingFilter.Type type, CloseableExecutorService executor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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)
-
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, 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
-
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
getSimplifiedLogger
-
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
-
Methods inherited from interface org.apache.sshd.common.channel.ChannelListenerManager
addChannelListener, getChannelListenerProxy, removeChannelListener
-
Methods inherited from interface org.apache.sshd.common.channel.throttle.ChannelStreamPacketWriterResolverManager
getChannelStreamPacketWriterResolver, resolveChannelStreamPacketWriter, resolveChannelStreamPacketWriterResolver, setChannelStreamPacketWriterResolver
-
Methods inherited from interface org.apache.sshd.common.Closeable
addCloseFutureListener, close, close, isClosed, isClosing, isOpen, removeCloseFutureListener
-
Methods inherited from interface org.apache.sshd.common.io.PacketWriter
writePacket
-
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 Detail
-
type
private final TcpForwardingFilter.Type type
-
connector
private IoConnector connector
-
ioSession
private IoSession ioSession
-
out
private java.io.OutputStream out
-
tunnelEntrance
private SshdSocketAddress tunnelEntrance
-
tunnelExit
private SshdSocketAddress tunnelExit
-
originatorAddress
private SshdSocketAddress originatorAddress
-
localAddress
private java.net.SocketAddress localAddress
-
-
Constructor Detail
-
TcpipServerChannel
public TcpipServerChannel(TcpForwardingFilter.Type type, CloseableExecutorService executor)
-
-
Method Detail
-
getTcpipChannelType
public TcpForwardingFilter.Type getTcpipChannelType()
-
getLocalAddress
public java.net.SocketAddress getLocalAddress()
-
setLocalAddress
public void setLocalAddress(java.net.SocketAddress localAddress)
-
getTunnelEntrance
public SshdSocketAddress getTunnelEntrance()
- Specified by:
getTunnelEntrance
in interfaceForwardingTunnelEndpointsProvider
-
getTunnelExit
public SshdSocketAddress getTunnelExit()
- Specified by:
getTunnelExit
in interfaceForwardingTunnelEndpointsProvider
-
getOriginatorAddress
public SshdSocketAddress getOriginatorAddress()
-
getIoSession
public IoSession getIoSession()
-
doInit
protected OpenFuture doInit(Buffer buffer)
- Overrides:
doInit
in classAbstractServerChannel
-
handleChannelConnectResult
protected void handleChannelConnectResult(OpenFuture f, IoConnectFuture future)
-
handleChannelOpenSuccess
protected void handleChannelOpenSuccess(OpenFuture f, IoSession session)
-
handleChannelOpenFailure
protected void handleChannelOpenFailure(OpenFuture f, java.lang.Throwable problem)
-
getInnerCloseable
protected Closeable getInnerCloseable()
- Overrides:
getInnerCloseable
in classAbstractChannel
-
doWriteData
protected void doWriteData(byte[] data, int off, long len) throws java.io.IOException
- Specified by:
doWriteData
in classAbstractChannel
- Throws:
java.io.IOException
-
doWriteExtendedData
protected void doWriteExtendedData(byte[] data, int off, long len) throws java.io.IOException
- Specified by:
doWriteExtendedData
in classAbstractChannel
- Throws:
java.io.IOException
-
handleWriteDataSuccess
protected void handleWriteDataSuccess(byte cmd, byte[] data, int off, int len)
-
handleWriteDataFailure
protected void handleWriteDataFailure(byte cmd, byte[] data, int off, int len, java.lang.Throwable t)
-
-