Class TcpipServerChannel

java.lang.Object

org.apache.sshd.common.util.logging.AbstractLoggingBean

org.apache.sshd.common.util.closeable.IoBaseCloseable

org.apache.sshd.common.util.closeable.AbstractCloseable

org.apache.sshd.common.util.closeable.AbstractInnerCloseable

org.apache.sshd.common.channel.AbstractChannel

org.apache.sshd.server.channel.AbstractServerChannel

org.apache.sshd.server.forward.TcpipServerChannel

All Implemented Interfaces:

Closeable, AutoCloseable, Channel, AttributeRepository, AttributeStore, Channel, ChannelIdentifier, ChannelListenerManager, ChannelStreamWriterResolver, ChannelStreamWriterResolverManager, Closeable, ForwardingTunnelEndpointsProvider, 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
(package private) class	TcpipServerChannel.PortIoHandler
static class	TcpipServerChannel.TcpipFactory

Nested classes/interfaces inherited from class AbstractChannel

AbstractChannel.GracefulChannelCloseable, AbstractChannel.GracefulState, AbstractChannel.PacketValidator

Nested classes/interfaces inherited from class AbstractCloseable

AbstractCloseable.State

Nested classes/interfaces inherited from interface AttributeRepository

AttributeRepository.AttributeKey<T>

Field Summary

Fields

Modifier and Type	Field	Description
private IoConnector	connector
private SocketAddress	localAddress
private SshdSocketAddress	originatorAddress
private ChannelAsyncOutputStream	out
private ChannelToPortHandler	port
private SshdSocketAddress	tunnelEntrance
private SshdSocketAddress	tunnelExit
private final TcpForwardingFilter.Type	type

Fields inherited from class AbstractServerChannel

exitStatusSent

Fields inherited from class AbstractChannel

channelListenerProxy, channelListeners, closeSignaled, DEFAULT_PACKET_VALIDATOR, eofReceived, eofSent, gracefulFuture, gracefulState, initialized, RESPONSE_BUFFER_GROWTH_FACTOR, service, unregisterSignaled

Fields inherited from class AbstractCloseable

closeFuture, futureLock, state

Fields inherited from class AbstractLoggingBean

log

Fields inherited from interface Channel

CHANNEL_EXEC, CHANNEL_SHELL, CHANNEL_SUBSYSTEM

Fields inherited from interface ChannelStreamWriterResolver

NONE

Fields inherited from interface PropertyResolver

EMPTY

Constructor Summary

Constructors

Constructor	Description
TcpipServerChannel(TcpForwardingFilter.Type type, CloseableExecutorService executor)

Method Summary

Modifier and Type	Method	Description
protected ChannelToPortHandler	createChannelToPortHandler(IoSession session)
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()
SocketAddress	getLocalAddress()
SshdSocketAddress	getOriginatorAddress()
ChannelToPortHandler	getPort()	Retrieves the ChannelToPortHandler.
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)
void	handleEof()	Invoked when SSH_MSG_CHANNEL_EOF received
void	handleWindowAdjust(Buffer buffer)	Invoked when SSH_MSG_CHANNEL_WINDOW_ADJUST received
protected boolean	mayWrite()
void	setLocalAddress(SocketAddress localAddress)

Methods inherited from class AbstractServerChannel

handleOpenFailure, handleOpenSuccess, open, sendExitStatus

Methods inherited from class AbstractChannel

addChannelListener, addPendingRequest, addRequestHandler, attributeKeys, clearAttributes, computeAttributeIfAbsent, configureWindow, getAttribute, getAttributesCount, getChannelId, getChannelListenerProxy, getChannelStreamWriterResolver, getExecutorService, getLocalWindow, getPacketValidator, getParentPropertyResolver, getProperties, getRecipient, getRemoteWindow, getRequestHandlers, getSession, handleChannelRegistrationResult, handleChannelRequest, handleChannelUnregistration, handleClose, handleData, handleExtendedData, handleFailure, handleInternalRequest, handleRequest, handleSuccess, handleUnknownChannelRequest, init, invokeChannelSignaller, isEofSent, isEofSignalled, isInitialized, notifyStateChanged, notifyStateChanged, preClose, removeAttribute, removeChannelListener, removePendingRequest, removeRequestHandler, resolveChannelStreamWriterResolver, sendEof, sendResponse, sendWindowAdjust, setAttribute, setChannelStreamWriterResolver, setPacketValidator, setRecipient, signalChannelClosed, signalChannelClosed, signalChannelInitialized, signalChannelInitialized, signalChannelOpenFailure, signalChannelOpenFailure, signalChannelOpenSuccess, signalChannelOpenSuccess, toString, validateIncomingDataSize, writePacket

Methods inherited from class AbstractInnerCloseable

doCloseGracefully, doCloseImmediately

Methods inherited from class AbstractCloseable

addCloseFutureListener, builder, close, getFutureLock, isClosed, isClosing, removeCloseFutureListener

Methods inherited from class 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 Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface AttributeRepository

attributeKeys, getAttribute, getAttributesCount

Methods inherited from interface AttributeStore

clearAttributes, computeAttributeIfAbsent, removeAttribute, setAttribute

Methods inherited from interface Channel

addRequestHandler, addRequestHandlers, getLocalWindow, getRecipient, getRemoteWindow, getRequestHandlers, handleChannelRegistrationResult, handleChannelUnregistration, handleClose, handleData, handleExtendedData, handleFailure, handleRequest, handleSuccess, init, isEofSignalled, isInitialized, removeRequestHandler, removeRequestHandlers, resolveAttribute, writePacket

Methods inherited from interface ChannelIdentifier

getChannelId

Methods inherited from interface ChannelListenerManager

addChannelListener, getChannelListenerProxy, removeChannelListener

Methods inherited from interface ChannelStreamWriterResolverManager

getChannelStreamWriterResolver, resolveChannelStreamWriter, resolveChannelStreamWriterResolver, setChannelStreamWriterResolver

Methods inherited from interface Closeable

addCloseFutureListener, close, close, isClosed, isClosing, isOpen, removeCloseFutureListener

Methods inherited from interface PropertyResolver

getBoolean, getBooleanProperty, getCharset, getInteger, getIntProperty, getLong, getLongProperty, getObject, getParentPropertyResolver, getProperties, getString, getStringProperty, isEmpty

Methods inherited from interface ServerChannel

getServerSession

Methods inherited from interface SessionHolder

getSession, getSessionContext

Field Details

type

private final TcpForwardingFilter.Type type

connector

private IoConnector connector

port

private volatile ChannelToPortHandler port

out

private ChannelAsyncOutputStream out

tunnelEntrance

private SshdSocketAddress tunnelEntrance

tunnelExit

private SshdSocketAddress tunnelExit

originatorAddress

private SshdSocketAddress originatorAddress

localAddress

private SocketAddress localAddress

Constructor Details

TcpipServerChannel

public TcpipServerChannel(TcpForwardingFilter.Type type,
 CloseableExecutorService executor)

Method Details

getTcpipChannelType

public TcpForwardingFilter.Type getTcpipChannelType()

getLocalAddress

public SocketAddress getLocalAddress()

setLocalAddress

public void setLocalAddress(SocketAddress localAddress)

getTunnelEntrance

public SshdSocketAddress getTunnelEntrance()

Specified by:

getTunnelEntrance in interface ForwardingTunnelEndpointsProvider

getTunnelExit

public SshdSocketAddress getTunnelExit()

Specified by:

getTunnelExit in interface ForwardingTunnelEndpointsProvider

getOriginatorAddress

public SshdSocketAddress getOriginatorAddress()

handleWindowAdjust

public void handleWindowAdjust(Buffer buffer)
                        throws IOException

Description copied from interface: Channel

Invoked when SSH_MSG_CHANNEL_WINDOW_ADJUST received

Specified by:

handleWindowAdjust in interface Channel

Overrides:

handleWindowAdjust in class AbstractChannel

Parameters:

buffer - The rest of the message data Buffer after decoding the channel identifiers

Throws:

IOException - If failed to handle the message

doInit

protected OpenFuture doInit(Buffer buffer)

Overrides:

doInit in class AbstractServerChannel

getPort

public ChannelToPortHandler getPort()

Retrieves the ChannelToPortHandler. This is null when the forwarding connection is not open.

Returns:

the port handler, if set, or null otherwise

mayWrite

protected boolean mayWrite()

Overrides:

mayWrite in class AbstractChannel

handleChannelConnectResult

protected void handleChannelConnectResult(OpenFuture f,
 IoConnectFuture future)

handleChannelOpenSuccess

protected void handleChannelOpenSuccess(OpenFuture f,
 IoSession session)

handleChannelOpenFailure

protected void handleChannelOpenFailure(OpenFuture f,
 Throwable problem)

handleEof

public void handleEof()
               throws IOException

Description copied from interface: Channel

Invoked when SSH_MSG_CHANNEL_EOF received

Specified by:

handleEof in interface Channel

Overrides:

handleEof in class AbstractChannel

Throws:

IOException - If failed to handle the message

getInnerCloseable

protected Closeable getInnerCloseable()

Overrides:

getInnerCloseable in class AbstractChannel

doWriteData

protected void doWriteData(byte[] data,
 int off,
 long len)
                    throws IOException

Specified by:

doWriteData in class AbstractChannel

Throws:

IOException

doWriteExtendedData

protected void doWriteExtendedData(byte[] data,
 int off,
 long len)
                            throws IOException

Specified by:

doWriteExtendedData in class AbstractChannel

Throws:

IOException

createChannelToPortHandler

protected ChannelToPortHandler createChannelToPortHandler(IoSession session)