org.apache.sshd.common.session.helpers

Class AbstractConnectionService

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.session.helpers.AbstractConnectionService

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.Channel, PortForwardingEventListenerManager, PortForwardingEventListenerManagerHolder, Service, ConnectionService, UnknownChannelReferenceHandlerManager

Direct Known Subclasses:

ClientConnectionService, ServerConnectionService

public abstract class AbstractConnectionService
extends AbstractInnerCloseable
implements ConnectionService

Base implementation of ConnectionService.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.sshd.common.util.closeable.AbstractCloseable

AbstractCloseable.State

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.atomic.AtomicReference<AgentForwardSupport>	agentForwardHolder
private java.util.concurrent.atomic.AtomicBoolean	allowMoreSessions
protected java.util.Map<java.lang.Integer,Channel>	channels Map of channels keyed by the identifier
static int	DEFAULT_MAX_CHANNELS Default value for MAX_CONCURRENT_CHANNELS_PROP is none specified
private java.util.concurrent.atomic.AtomicReference<ForwardingFilter>	forwarderHolder
private PortForwardingEventListener	listenerProxy
private java.util.Collection<PortForwardingEventListener>	listeners
private java.util.Collection<PortForwardingEventListenerManager>	managersHolder
static java.lang.String	MAX_CONCURRENT_CHANNELS_PROP Property that can be used to configure max.
protected java.util.concurrent.atomic.AtomicInteger	nextChannelId Next channel identifier
static java.util.function.IntUnaryOperator	RESPONSE_BUFFER_GROWTH_FACTOR Default growth factor function used to resize response buffers
private AbstractSession	sessionInstance
private UnknownChannelReferenceHandler	unknownChannelReferenceHandler
private java.util.concurrent.atomic.AtomicReference<X11ForwardSupport>	x11ForwardHolder

Fields inherited from class org.apache.sshd.common.util.closeable.AbstractCloseable

closeFuture, lock, state

Fields inherited from class org.apache.sshd.common.util.logging.AbstractLoggingBean

log

Fields inherited from interface org.apache.sshd.common.Closeable

CLOSE_WAIT_TIMEOUT, DEFAULT_CLOSE_WAIT_TIMEOUT

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractConnectionService(AbstractSession session)

Method Summary

Modifier and Type	Method and Description
void	addPortForwardingEventListener(PortForwardingEventListener listener) Add a port forwarding listener
boolean	addPortForwardingEventListenerManager(PortForwardingEventListenerManager manager)
void	channelClose(Buffer buffer) Close a channel due to a close packet received
void	channelData(Buffer buffer) Process incoming data on a channel
void	channelEof(Buffer buffer) Process end of file on a channel
void	channelExtendedData(Buffer buffer) Process incoming extended data on a channel
void	channelFailure(Buffer buffer) Process a failure on a channel
protected void	channelOpen(Buffer buffer)
void	channelOpenConfirmation(Buffer buffer)
void	channelOpenFailure(Buffer buffer)
void	channelRequest(Buffer buffer) Service a request on a channel
void	channelSuccess(Buffer buffer) Process a success on a channel
void	channelWindowAdjust(Buffer buffer) Process a window adjust packet on a channel
protected AgentForwardSupport	createAgentForwardSupport(AbstractSession session)
protected ForwardingFilter	createForwardingFilter(AbstractSession session)
protected X11ForwardSupport	createX11ForwardSupport(AbstractSession session)
AgentForwardSupport	getAgentForwardSupport()
protected Channel	getChannel(byte cmd, Buffer buffer) Retrieve the channel designated by the given packet
protected Channel	getChannel(byte cmd, int recipient, Buffer buffer)
java.util.Collection<Channel>	getChannels()
ForwardingFilter	getForwardingFilter() Retrieve the forwarder instance
protected Closeable	getInnerCloseable()
protected int	getNextChannelId()
PortForwardingEventListener	getPortForwardingEventListenerProxy()
java.util.Collection<PortForwardingEventListenerManager>	getRegisteredManagers()
AbstractSession	getSession()
UnknownChannelReferenceHandler	getUnknownChannelReferenceHandler()
X11ForwardSupport	getX11ForwardSupport()
protected IoWriteFuture	globalRequest(Buffer buffer) Process global requests
protected void	handleChannelRegistrationFailure(Channel channel, int channelId)
protected IoWriteFuture	handleUnknownRequest(Buffer buffer, java.lang.String req, boolean wantReply)
boolean	isAllowMoreSessions()
protected void	preClose() preClose is guaranteed to be called before doCloseGracefully or doCloseImmediately.
void	process(int cmd, Buffer buffer) Service the request.
int	registerChannel(Channel channel) Register a newly created channel with a new unique identifier
void	removePortForwardingEventListener(PortForwardingEventListener listener) Remove a port forwarding listener
boolean	removePortForwardingEventListenerManager(PortForwardingEventListenerManager manager)
protected void	requestFailure(Buffer buffer)
protected void	requestSuccess(Buffer buffer)
UnknownChannelReferenceHandler	resolveUnknownChannelReferenceHandler() Check if current manager has a specific handler set for it - if not, try and resolve one from the "parent" container (if any)
protected IoWriteFuture	sendChannelOpenFailure(Buffer buffer, int sender, int reasonCode, java.lang.String message, java.lang.String lang)
protected IoWriteFuture	sendGlobalResponse(Buffer buffer, java.lang.String req, RequestHandler.Result result, boolean wantReply)
void	setAllowMoreSessions(boolean allow)
void	setUnknownChannelReferenceHandler(UnknownChannelReferenceHandler handler)
void	start()
java.lang.String	toString()
void	unregisterChannel(Channel channel) Remove this channel from the list of managed channels

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

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

Field Detail

MAX_CONCURRENT_CHANNELS_PROP

public static final java.lang.String MAX_CONCURRENT_CHANNELS_PROP

Property that can be used to configure max. allowed concurrent active channels

See Also:

registerChannel(Channel), Constant Field Values

DEFAULT_MAX_CHANNELS

public static final int DEFAULT_MAX_CHANNELS

Default value for MAX_CONCURRENT_CHANNELS_PROP is none specified

See Also:

Constant Field Values

RESPONSE_BUFFER_GROWTH_FACTOR

public static final java.util.function.IntUnaryOperator RESPONSE_BUFFER_GROWTH_FACTOR

Default growth factor function used to resize response buffers

channels

protected final java.util.Map<java.lang.Integer,Channel> channels

Map of channels keyed by the identifier

nextChannelId

protected final java.util.concurrent.atomic.AtomicInteger nextChannelId

Next channel identifier

agentForwardHolder

private final java.util.concurrent.atomic.AtomicReference<AgentForwardSupport> agentForwardHolder

x11ForwardHolder

private final java.util.concurrent.atomic.AtomicReference<X11ForwardSupport> x11ForwardHolder

forwarderHolder

private final java.util.concurrent.atomic.AtomicReference<ForwardingFilter> forwarderHolder

allowMoreSessions

private final java.util.concurrent.atomic.AtomicBoolean allowMoreSessions

listeners

private final java.util.Collection<PortForwardingEventListener> listeners

managersHolder

private final java.util.Collection<PortForwardingEventListenerManager> managersHolder

listenerProxy

private final PortForwardingEventListener listenerProxy

sessionInstance

private final AbstractSession sessionInstance

unknownChannelReferenceHandler

private UnknownChannelReferenceHandler unknownChannelReferenceHandler

Constructor Detail

AbstractConnectionService

protected AbstractConnectionService(AbstractSession session)

Method Detail

getPortForwardingEventListenerProxy

public PortForwardingEventListener getPortForwardingEventListenerProxy()

Specified by:

getPortForwardingEventListenerProxy in interface PortForwardingEventListenerManager

Returns:

A proxy listener representing all the currently registered listener through this manager

addPortForwardingEventListener

public void addPortForwardingEventListener(PortForwardingEventListener listener)

Description copied from interface: PortForwardingEventListenerManager

Add a port forwarding listener

Specified by:

addPortForwardingEventListener in interface PortForwardingEventListenerManager

Parameters:

listener - The PortForwardingEventListener to add - never null

removePortForwardingEventListener

public void removePortForwardingEventListener(PortForwardingEventListener listener)

Description copied from interface: PortForwardingEventListenerManager

Remove a port forwarding listener

Specified by:

removePortForwardingEventListener in interface PortForwardingEventListenerManager

Parameters:

listener - The PortForwardingEventListener to remove - ignored if null

getUnknownChannelReferenceHandler

public UnknownChannelReferenceHandler getUnknownChannelReferenceHandler()

Specified by:

getUnknownChannelReferenceHandler in interface UnknownChannelReferenceHandlerManager

Returns:

The UnknownChannelReferenceHandlerManager to use - if null then any reference to unknown channel causes an SshChannelNotFoundException

setUnknownChannelReferenceHandler

public void setUnknownChannelReferenceHandler(UnknownChannelReferenceHandler handler)

Specified by:

setUnknownChannelReferenceHandler in interface UnknownChannelReferenceHandlerManager

Parameters:

handler - The UnknownChannelReferenceHandlerManager to use - if null then any reference to unknown channel causes an SshChannelNotFoundException

getRegisteredManagers

public java.util.Collection<PortForwardingEventListenerManager> getRegisteredManagers()

Specified by:

getRegisteredManagers in interface PortForwardingEventListenerManagerHolder

Returns:

The currently registered managers. Note: it is highly recommended that implementors return either an un-modifiable collection or a copy of the current one. Callers, should avoid modifying the retrieved value.

addPortForwardingEventListenerManager

public boolean addPortForwardingEventListenerManager(PortForwardingEventListenerManager manager)

Specified by:

addPortForwardingEventListenerManager in interface PortForwardingEventListenerManagerHolder

removePortForwardingEventListenerManager

public boolean removePortForwardingEventListenerManager(PortForwardingEventListenerManager manager)

Specified by:

removePortForwardingEventListenerManager in interface PortForwardingEventListenerManagerHolder

getChannels

public java.util.Collection<Channel> getChannels()

getSession

public AbstractSession getSession()

Specified by:

getSession in interface Service

start

public void start()

Specified by:

start in interface Service

getForwardingFilter

public ForwardingFilter getForwardingFilter()

Description copied from interface: ConnectionService

Retrieve the forwarder instance

Specified by:

getForwardingFilter in interface ConnectionService

Returns:

The ForwardingFilter

preClose

protected void preClose()

Description copied from class: AbstractCloseable

preClose is guaranteed to be called before doCloseGracefully or doCloseImmediately. When preClose() is called, isClosing() == true

Overrides:

preClose in class AbstractCloseable

createForwardingFilter

protected ForwardingFilter createForwardingFilter(AbstractSession session)

getX11ForwardSupport

public X11ForwardSupport getX11ForwardSupport()

Specified by:

getX11ForwardSupport in interface ConnectionService

createX11ForwardSupport

protected X11ForwardSupport createX11ForwardSupport(AbstractSession session)

getAgentForwardSupport

public AgentForwardSupport getAgentForwardSupport()

Specified by:

getAgentForwardSupport in interface ConnectionService

createAgentForwardSupport

protected AgentForwardSupport createAgentForwardSupport(AbstractSession session)

getInnerCloseable

protected Closeable getInnerCloseable()

Specified by:

getInnerCloseable in class AbstractInnerCloseable

getNextChannelId

protected int getNextChannelId()

registerChannel

public int registerChannel(Channel channel)
                    throws java.io.IOException

Description copied from interface: ConnectionService

Register a newly created channel with a new unique identifier

Specified by:

registerChannel in interface ConnectionService

Parameters:

channel - The Channel to register

Returns:

The assigned id of this channel

Throws:

java.io.IOException - If failed to initialize and register the channel

handleChannelRegistrationFailure

protected void handleChannelRegistrationFailure(Channel channel,
                                                int channelId)
                                         throws java.io.IOException

Throws:

java.io.IOException

unregisterChannel

public void unregisterChannel(Channel channel)

Remove this channel from the list of managed channels

Specified by:

unregisterChannel in interface ConnectionService

Parameters:

channel - the channel

process

public void process(int cmd,
                    Buffer buffer)
             throws java.lang.Exception

Description copied from interface: Service

Service the request.

Specified by:

process in interface Service

Parameters:

cmd - The incoming command type

buffer - The Buffer containing optional command parameters

Throws:

java.lang.Exception - If failed to process the command

isAllowMoreSessions

public boolean isAllowMoreSessions()

Specified by:

isAllowMoreSessions in interface ConnectionService

setAllowMoreSessions

public void setAllowMoreSessions(boolean allow)

Specified by:

setAllowMoreSessions in interface ConnectionService

channelOpenConfirmation

public void channelOpenConfirmation(Buffer buffer)
                             throws java.io.IOException

Throws:

java.io.IOException

channelOpenFailure

public void channelOpenFailure(Buffer buffer)
                        throws java.io.IOException

Throws:

java.io.IOException

channelData

public void channelData(Buffer buffer)
                 throws java.io.IOException

Process incoming data on a channel

Parameters:

buffer - the buffer containing the data

Throws:

java.io.IOException - if an error occurs

channelExtendedData

public void channelExtendedData(Buffer buffer)
                         throws java.io.IOException

Process incoming extended data on a channel

Parameters:

buffer - the buffer containing the data

Throws:

java.io.IOException - if an error occurs

channelWindowAdjust

public void channelWindowAdjust(Buffer buffer)
                         throws java.io.IOException

Process a window adjust packet on a channel

Parameters:

buffer - the buffer containing the window adjustment parameters

Throws:

java.io.IOException - if an error occurs

channelEof

public void channelEof(Buffer buffer)
                throws java.io.IOException

Process end of file on a channel

Parameters:

buffer - the buffer containing the packet

Throws:

java.io.IOException - if an error occurs

channelClose

public void channelClose(Buffer buffer)
                  throws java.io.IOException

Close a channel due to a close packet received

Parameters:

buffer - the buffer containing the packet

Throws:

java.io.IOException - if an error occurs

channelRequest

public void channelRequest(Buffer buffer)
                    throws java.io.IOException

Service a request on a channel

Parameters:

buffer - the buffer containing the request

Throws:

java.io.IOException - if an error occurs

channelFailure

public void channelFailure(Buffer buffer)
                    throws java.io.IOException

Process a failure on a channel

Parameters:

buffer - the buffer containing the packet

Throws:

java.io.IOException - if an error occurs

channelSuccess

public void channelSuccess(Buffer buffer)
                    throws java.io.IOException

Process a success on a channel

Parameters:

buffer - the buffer containing the packet

Throws:

java.io.IOException - if an error occurs

getChannel

protected Channel getChannel(byte cmd,
                             Buffer buffer)
                      throws java.io.IOException

Retrieve the channel designated by the given packet

Parameters:

cmd - The command being processed for the channel

buffer - the incoming packet

Returns:

the target channel

Throws:

java.io.IOException - if the channel does not exists

getChannel

protected Channel getChannel(byte cmd,
                             int recipient,
                             Buffer buffer)
                      throws java.io.IOException

Throws:

java.io.IOException

resolveUnknownChannelReferenceHandler

public UnknownChannelReferenceHandler resolveUnknownChannelReferenceHandler()

Description copied from interface: UnknownChannelReferenceHandlerManager

Check if current manager has a specific handler set for it - if not, try and resolve one from the "parent" container (if any)

Specified by:

resolveUnknownChannelReferenceHandler in interface UnknownChannelReferenceHandlerManager

Returns:

The resolved handler instance

channelOpen

protected void channelOpen(Buffer buffer)
                    throws java.lang.Exception

Throws:

java.lang.Exception

sendChannelOpenFailure

protected IoWriteFuture sendChannelOpenFailure(Buffer buffer,
                                               int sender,
                                               int reasonCode,
                                               java.lang.String message,
                                               java.lang.String lang)
                                        throws java.io.IOException

Throws:

java.io.IOException

globalRequest

protected IoWriteFuture globalRequest(Buffer buffer)
                               throws java.lang.Exception

Process global requests

Parameters:

buffer - The request Buffer

Returns:

An IoWriteFuture representing the sent packet - Note: if no reply sent then an "empty" future is returned - i.e., any added listeners are triggered immediately with a synthetic "success"

Throws:

java.lang.Exception - If failed to process the request

handleUnknownRequest

protected IoWriteFuture handleUnknownRequest(Buffer buffer,
                                             java.lang.String req,
                                             boolean wantReply)
                                      throws java.io.IOException

Throws:

java.io.IOException

sendGlobalResponse

protected IoWriteFuture sendGlobalResponse(Buffer buffer,
                                           java.lang.String req,
                                           RequestHandler.Result result,
                                           boolean wantReply)
                                    throws java.io.IOException

Throws:

java.io.IOException

requestSuccess

protected void requestSuccess(Buffer buffer)
                       throws java.lang.Exception

Throws:

java.lang.Exception

requestFailure

protected void requestFailure(Buffer buffer)
                       throws java.lang.Exception

Throws:

java.lang.Exception

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object