public class ClientConnectionService extends AbstractConnectionService implements ClientSessionHolder
ssh-connection
service.AbstractCloseable.State
channels, DEFAULT_MAX_CHANNELS, MAX_CONCURRENT_CHANNELS_PROP, nextChannelId, RESPONSE_BUFFER_GROWTH_FACTOR
closeFuture, lock, state
log
CLOSE_WAIT_TIMEOUT, DEFAULT_CLOSE_WAIT_TIMEOUT
Constructor and Description |
---|
ClientConnectionService(AbstractClientSession s) |
Modifier and Type | Method and Description |
---|---|
protected void |
futureDone(IoWriteFuture future) |
AgentForwardSupport |
getAgentForwardSupport() |
ClientSession |
getClientSession() |
AbstractClientSession |
getSession() |
X11ForwardSupport |
getX11ForwardSupport() |
protected void |
preClose()
preClose is guaranteed to be called before doCloseGracefully or doCloseImmediately.
|
protected IoWriteFuture |
sendHeartBeat()
Sends a heartbeat message
|
void |
start() |
protected void |
startHeartBeat() |
protected void |
stopHeartBeat() |
addPortForwardingEventListener, addPortForwardingEventListenerManager, channelClose, channelData, channelEof, channelExtendedData, channelFailure, channelOpen, channelOpenConfirmation, channelOpenFailure, channelRequest, channelSuccess, channelWindowAdjust, createAgentForwardSupport, createForwardingFilter, createX11ForwardSupport, getChannel, getChannel, getChannels, getForwardingFilter, getInnerCloseable, getNextChannelId, getPortForwardingEventListenerProxy, getRegisteredManagers, getUnknownChannelReferenceHandler, globalRequest, handleChannelRegistrationFailure, handleUnknownRequest, isAllowMoreSessions, process, registerChannel, removePortForwardingEventListener, removePortForwardingEventListenerManager, requestFailure, requestSuccess, resolveUnknownChannelReferenceHandler, sendChannelOpenFailure, sendGlobalResponse, setAllowMoreSessions, setUnknownChannelReferenceHandler, toString, unregisterChannel
doCloseGracefully, doCloseImmediately
addCloseFutureListener, builder, close, isClosed, isClosing, removeCloseFutureListener
getSimplifiedLogger
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addCloseFutureListener, close, close, close, getMaxCloseWaitTime, isClosed, isClosing, isOpen, removeCloseFutureListener
public ClientConnectionService(AbstractClientSession s) throws SshException
SshException
public final ClientSession getClientSession()
getClientSession
in interface ClientSessionHolder
ClientSession
usedpublic AbstractClientSession getSession()
getSession
in interface Service
getSession
in class AbstractConnectionService
public void start()
start
in interface Service
start
in class AbstractConnectionService
protected void preClose()
AbstractCloseable
preClose
in class AbstractConnectionService
protected void startHeartBeat()
protected void stopHeartBeat()
protected IoWriteFuture sendHeartBeat()
IoWriteFuture
that can be used to wait for the
message write completionprotected void futureDone(IoWriteFuture future)
public AgentForwardSupport getAgentForwardSupport()
getAgentForwardSupport
in interface ConnectionService
getAgentForwardSupport
in class AbstractConnectionService
public X11ForwardSupport getX11ForwardSupport()
getX11ForwardSupport
in interface ConnectionService
getX11ForwardSupport
in class AbstractConnectionService
Copyright © 2008–2022 The Apache Software Foundation. All rights reserved.