Package org.apache.sshd.server.forward

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, 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 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>

Nested classes/interfaces inherited from interface org.apache.sshd.common.channel.StreamingChannel

StreamingChannel.Streaming

Field Summary

Fields

Modifier and Type	Field	Description
private IoConnector	connector
private final AtomicLong	inFlightDataSize
private IoSession	ioSession
private SocketAddress	localAddress
private SshdSocketAddress	originatorAddress
private IoOutputStream	out
private StreamingChannel.Streaming	streaming
private SshdSocketAddress	tunnelEntrance
private SshdSocketAddress	tunnelExit
private final 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, closeSignaled, eofReceived, eofSent, gracefulFuture, gracefulState, initialized, RESPONSE_BUFFER_GROWTH_FACTOR, service, unregisterSignaled

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

Constructors

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

Method Summary

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()
SocketAddress	getLocalAddress()
SshdSocketAddress	getOriginatorAddress()
StreamingChannel.Streaming	getStreaming()
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)
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, handleChannelRegistrationResult, handleChannelRequest, handleChannelUnregistration, 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, handleChannelRegistrationResult, handleChannelUnregistration, 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, isEmpty

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

private final TcpForwardingFilter.Type type

connector

private IoConnector connector

ioSession

private IoSession ioSession

out

private IoOutputStream out

tunnelEntrance

private SshdSocketAddress tunnelEntrance

tunnelExit

private SshdSocketAddress tunnelExit

originatorAddress

private SshdSocketAddress originatorAddress

localAddress

private SocketAddress localAddress

inFlightDataSize

private final AtomicLong inFlightDataSize

streaming

private StreamingChannel.Streaming streaming

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)

getStreaming

public StreamingChannel.Streaming getStreaming()

Specified by:

getStreaming in interface StreamingChannel

setStreaming

public void setStreaming(StreamingChannel.Streaming streaming)

Specified by:

setStreaming in interface StreamingChannel

getTunnelEntrance

public SshdSocketAddress getTunnelEntrance()

Specified by:

getTunnelEntrance in interface ForwardingTunnelEndpointsProvider

getTunnelExit

public SshdSocketAddress getTunnelExit()

Specified by:

getTunnelExit in interface ForwardingTunnelEndpointsProvider

getOriginatorAddress

public SshdSocketAddress getOriginatorAddress()

getIoSession

public IoSession getIoSession()

doInit

protected OpenFuture doInit(Buffer buffer)

Overrides:

doInit in class AbstractServerChannel

handleChannelConnectResult

protected void handleChannelConnectResult(OpenFuture f,
 IoConnectFuture future)

handleChannelOpenSuccess

protected void handleChannelOpenSuccess(OpenFuture f,
 IoSession session)

handleChannelOpenFailure

protected void handleChannelOpenFailure(OpenFuture f,
 Throwable problem)

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

handleWriteDataSuccess

protected void handleWriteDataSuccess(byte cmd,
 byte[] data,
 int off,
 int len)

handleWriteDataFailure

protected void handleWriteDataFailure(byte cmd,
 byte[] data,
 int off,
 int len,
 Throwable t)