Package org.eclipse.jgit.internal.transport.sshd

Class JGitClientSession

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.kex.AbstractKexFactoryManager

org.apache.sshd.common.session.helpers.SessionHelper

org.apache.sshd.common.session.helpers.AbstractSession

org.apache.sshd.client.session.AbstractClientSession

org.apache.sshd.client.session.ClientSessionImpl

org.eclipse.jgit.internal.transport.sshd.JGitClientSession

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.Channel, org.apache.sshd.client.ClientAuthenticationManager, org.apache.sshd.client.session.ClientProxyConnectorHolder, org.apache.sshd.client.session.ClientSession, org.apache.sshd.common.AttributeRepository, org.apache.sshd.common.AttributeStore, org.apache.sshd.common.auth.MutableUserHolder, org.apache.sshd.common.auth.UserAuthFactoriesManager<org.apache.sshd.client.session.ClientSession,org.apache.sshd.client.auth.UserAuth,org.apache.sshd.client.auth.UserAuthFactory>, org.apache.sshd.common.auth.UsernameHolder, org.apache.sshd.common.channel.ChannelListenerManager, org.apache.sshd.common.channel.throttle.ChannelStreamPacketWriterResolver, org.apache.sshd.common.channel.throttle.ChannelStreamPacketWriterResolverManager, org.apache.sshd.common.Closeable, org.apache.sshd.common.FactoryManagerHolder, org.apache.sshd.common.forward.PortForwardingEventListenerManager, org.apache.sshd.common.forward.PortForwardingInformationProvider, org.apache.sshd.common.forward.PortForwardingManager, org.apache.sshd.common.io.PacketWriter, org.apache.sshd.common.kex.extension.KexExtensionHandlerManager, org.apache.sshd.common.kex.KexFactoryManager, org.apache.sshd.common.keyprovider.KeyIdentityProviderHolder, org.apache.sshd.common.PropertyResolver, org.apache.sshd.common.session.ReservedSessionMessagesManager, org.apache.sshd.common.session.Session, org.apache.sshd.common.session.SessionContext, org.apache.sshd.common.session.SessionDisconnectHandlerManager, org.apache.sshd.common.session.SessionHeartbeatController, org.apache.sshd.common.session.SessionListenerManager, org.apache.sshd.common.session.UnknownChannelReferenceHandlerManager, org.apache.sshd.common.signature.SignatureFactoriesManager, org.apache.sshd.common.util.net.ConnectionEndpointsIndicator

public class JGitClientSession
extends org.apache.sshd.client.session.ClientSessionImpl

A ClientSession that can be associated with the HostConfigEntry the session was created for. The JGitSshClient creates such sessions and sets this association.

Also provides for associating a JGit CredentialsProvider with a session.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JGitClientSession.ChainingAttributes	An AttributeRepository that chains together two other attribute sources in a hierarchy.
static class	JGitClientSession.SessionAttributes	A JGitClientSession.ChainingAttributes repository that doubles as a PropertyResolver.

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

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

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

org.apache.sshd.common.AttributeRepository.AttributeKey<T extends java.lang.Object>

Nested classes/interfaces inherited from interface org.apache.sshd.client.session.ClientSession

org.apache.sshd.client.session.ClientSession.ClientSessionEvent

Nested classes/interfaces inherited from interface org.apache.sshd.common.session.SessionHeartbeatController

org.apache.sshd.common.session.SessionHeartbeatController.HeartbeatType

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.sshd.client.future.AuthFuture	authFuture	Work-around for bug 565394 / SSHD-1050; remove when using sshd 2.6.0.
private CredentialsProvider	credentialsProvider
private static int	DEFAULT_MAX_IDENTIFICATION_SIZE	Default setting for the maximum number of bytes to read in the initial protocol version exchange.
private java.util.List<java.lang.Throwable>	earlyErrors	Records exceptions before there is an authFuture.
private java.lang.Object	errorLock	Guards setting an earlyError and the authFuture together.
private org.apache.sshd.client.config.hosts.HostConfigEntry	hostConfig
private StatefulProxyConnector	proxyHandler

Fields inherited from class org.apache.sshd.client.session.AbstractClientSession

sendImmediateClientIdentification, sendImmediateKexInit

Fields inherited from class org.apache.sshd.common.session.helpers.AbstractSession

channelListenerProxy, channelListeners, clientProposal, clientVersion, currentService, decodeLock, decoderBuffer, decoderLength, decoderState, encodeLock, firstKexPacketFollows, ignorePacketDataLength, ignorePacketsCount, ignorePacketsFrequency, ignorePacketsVariance, inBlocksCount, inBytesCount, inCipher, inCipherSize, inCompression, inMac, inMacResult, inMacSize, inPacketsCount, kex, kexFutureHolder, kexState, lastKeyTimeValue, maxRekeyBlocks, maxRekeyBytes, maxRekeyInterval, maxRekyPackets, negotiationResult, outBlocksCount, outBytesCount, outCipher, outCipherSize, outCompression, outMac, outMacSize, outPacketsCount, pendingPackets, random, requestLock, seqi, seqo, serverProposal, serverVersion, SESSION, sessionId, sessionListenerProxy, sessionListeners, tunnelListenerProxy, tunnelListeners, uncompressBuffer, unmodClientProposal, unmodNegotiationResult, unmodServerProposal

Fields inherited from class org.apache.sshd.common.session.helpers.SessionHelper

authNanoStart, idleNanoStart, sessionLock

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.throttle.ChannelStreamPacketWriterResolver

NONE

Fields inherited from interface org.apache.sshd.client.ClientAuthenticationManager

DEFAULT_PASSWORD_PROMPTS, PASSWORD_PROMPTS, PREFERRED_AUTHS

Fields inherited from interface org.apache.sshd.client.session.ClientSession

REMOTE_COMMAND_WAIT_EVENTS

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

Fields inherited from interface org.apache.sshd.common.session.SessionContext

DEFAULT_SSH_VERSION_PREFIX, FALLBACK_SSH_VERSION_PREFIX, MAX_VERSION_LINE_LENGTH

Fields inherited from interface org.apache.sshd.common.session.SessionHeartbeatController

DEFAULT_CONNECTION_HEARTBEAT_INTERVAL, SESSION_HEARTBEAT_INTERVAL, SESSION_HEARTBEAT_TYPE

Constructor Summary

Constructors

Constructor	Description
JGitClientSession(org.apache.sshd.client.ClientFactoryManager manager, org.apache.sshd.common.io.IoSession session)

Method Summary

Modifier and Type	Method	Description
org.apache.sshd.client.future.AuthFuture	auth()
protected void	checkKeys()
protected java.util.List<java.lang.String>	doReadIdentification(org.apache.sshd.common.util.buffer.Buffer buffer, boolean server)	Reads the RFC 4253, section 4.2 protocol version identification.
private static java.lang.String	escapeControls(java.lang.String s)
void	exceptionCaught(java.lang.Throwable t)
private java.util.List<java.lang.String>	filteredList(java.util.Set<java.lang.String> known, java.lang.String values)
<T> T	getAttribute(org.apache.sshd.common.AttributeRepository.AttributeKey<T> key)
CredentialsProvider	getCredentialsProvider()	Retrieves the CredentialsProvider set for this session.
org.apache.sshd.client.config.hosts.HostConfigEntry	getHostConfigEntry()	Retrieves the HostConfigEntry this session was created for.
org.apache.sshd.common.PropertyResolver	getParentPropertyResolver()
protected void	handleDisconnect(int code, java.lang.String msg, java.lang.String lang, org.apache.sshd.common.util.buffer.Buffer buffer)
void	messageReceived(org.apache.sshd.common.util.Readable buffer)	As long as we're still setting up the proxy connection, diverts messages to the StatefulProxyConnector.
protected void	preClose()
private void	removeFromList(java.util.Set<java.lang.String> current, java.lang.String key, java.lang.String patterns)
protected java.lang.String	resolveAvailableSignaturesProposal(org.apache.sshd.common.FactoryManager manager)
protected org.apache.sshd.common.io.IoWriteFuture	sendIdentification(java.lang.String ident)
protected byte[]	sendKexInit()
void	setCredentialsProvider(CredentialsProvider provider)	Sets the CredentialsProvider for this session.
void	setHostConfigEntry(org.apache.sshd.client.config.hosts.HostConfigEntry hostConfig)	Sets the HostConfigEntry this session was created for.
void	setProxyHandler(StatefulProxyConnector handler)	Sets a StatefulProxyConnector to handle proxy connection protocols.
private void	signalAuthFailure(java.lang.Throwable t)
protected void	signalAuthFailure(org.apache.sshd.client.future.AuthFuture future, java.lang.Throwable t)
protected <C extends java.util.Collection<org.apache.sshd.client.session.ClientSession.ClientSessionEvent>> C	updateCurrentSessionState(C newState)

Methods inherited from class org.apache.sshd.client.session.ClientSessionImpl

getMetadataMap, getServices, getSessionState, nextServiceName, sendInitialServiceRequest, signalSessionEvent, switchToNextService, waitFor

Methods inherited from class org.apache.sshd.client.session.AbstractClientSession

addPasswordIdentity, addPublicKeyIdentity, createChannel, createChannel, createDirectTcpipChannel, createExecChannel, createShellChannel, createSubsystemChannel, getClientProxyConnector, getConnectAddress, getConnectionContext, getConnectionService, getFactoryManager, getForwardingFilter, getKeyIdentityProvider, getPasswordIdentityProvider, getRegisteredIdentities, getServerKeyVerifier, getUserAuthFactories, getUserAuthService, getUserInteraction, initializeKeyExchangePhase, initializeProxyConnector, readIdentification, receiveKexInit, receiveKexInit, removePasswordIdentity, removePublicKeyIdentity, sendClientIdentification, sendKexInit, setClientProxyConnector, setConnectAddress, setKexSeed, setKeyIdentityProvider, setPasswordIdentityProvider, setServerKeyVerifier, setUserAuthFactories, setUserInteraction, signalExtraServerVersionInfo, startDynamicPortForwarding, startLocalPortForwarding, startRemotePortForwarding, startService, stopDynamicPortForwarding, stopLocalPortForwarding, stopRemotePortForwarding, switchToNoneCipher

Methods inherited from class org.apache.sshd.common.session.helpers.AbstractSession

addChannelListener, addPortForwardingEventListener, addSessionListener, appendOutgoingMac, attachSession, checkRekey, comparePreferredKexProposalOption, createBuffer, decode, doHandleMessage, doKexNegotiation, doWritePacket, encode, encryptOutgoingBuffer, getChannelListenerProxy, getCipherInformation, getClientKexData, getClientKexProposals, getClientVersion, getCompressionInformation, getInnerCloseable, getKex, getKexNegotiationResult, getKexState, getMacInformation, getNegotiatedKexParameter, getPortForwardingEventListenerProxy, getServerKexData, getServerKexProposals, getServerVersion, getService, getSession, getSession, getSessionId, getSessionListenerProxy, handleFirstKexPacketFollows, handleKexExtension, handleKexInit, handleKexMessage, handleMessage, handleNewCompression, handleNewKeys, handleServiceAccept, handleServiceAccept, handleServiceRequest, handleServiceRequest, isRekeyBlocksCountExceeded, isRekeyDataSizeExceeded, isRekeyPacketCountsExceeded, isRekeyRequired, isRekeyTimeIntervalExceeded, negotiate, notImplemented, prepareBuffer, receiveKexInit, receiveNewKeys, reExchangeKeys, refreshConfiguration, removeChannelListener, removePortForwardingEventListener, removeSessionListener, request, requestFailure, requestNewKeysExchange, requestSuccess, resolveAvailableSignaturesProposal, resolveIgnoreBufferDataLength, resolveOutputPacket, resolveSessionKexProposal, sendNewKeys, sendPendingPackets, setClientKexData, setNegotiationResult, setServerKexData, validateIncomingMac, validateKexState, validateTargetBuffer, writePacket

Methods inherited from class org.apache.sshd.common.session.helpers.SessionHelper

attributeKeys, calculateNextIgnorePacketCount, checkAuthenticationTimeout, checkForTimeouts, checkIdleTimeout, clearAttributes, computeAttributeIfAbsent, createProposal, disconnect, getAttributesCount, getAuthTimeout, getAuthTimeoutStart, getBoundLocalPortForward, getBoundRemotePortForward, getChannelStreamPacketWriterResolver, getIdleTimeout, getIdleTimeoutStart, getIoSession, getLocalForwardsBindings, getProperties, getRemoteForwardsBindings, getReservedSessionMessagesHandler, getSessionDisconnectHandler, getStartedLocalPortForwards, getStartedRemotePortForwards, getTimeoutStatus, getUnknownChannelReferenceHandler, getUsername, handleDebug, handleDisconnect, handleIgnore, handleUnimplemented, invokeSessionSignaller, isAuthenticated, isLocalPortForwardingStartedForPort, isRemotePortForwardingStartedForPort, isServerSession, mergeProposals, removeAttribute, resetAuthTimeout, resetIdleTimeout, resizeKey, resolveChannelStreamPacketWriterResolver, resolveIdentificationString, resolvePeerAddress, resolveReservedSessionMessagesHandler, resolveUnknownChannelReferenceHandler, sendDebugMessage, sendIgnoreMessage, sendNotImplemented, setAttribute, setAuthenticated, setChannelStreamPacketWriterResolver, setReservedSessionMessagesHandler, setSessionDisconnectHandler, setUnknownChannelReferenceHandler, setUsername, signalDisconnect, signalDisconnect, signalExceptionCaught, signalExceptionCaught, signalNegotiationEnd, signalNegotiationEnd, signalNegotiationStart, signalNegotiationStart, signalPeerIdentificationReceived, signalPeerIdentificationReceived, signalSessionClosed, signalSessionClosed, signalSessionCreated, signalSessionCreated, signalSessionEstablished, signalSessionEstablished, signalSessionEvent, toString, writePacket

Methods inherited from class org.apache.sshd.common.kex.AbstractKexFactoryManager

getCipherFactories, getCompressionFactories, getDelegate, getKexExtensionHandler, getKeyExchangeFactories, getMacFactories, getSignatureFactories, resolveEffectiveFactories, resolveEffectiveProvider, setCipherFactories, setCompressionFactories, setKexExtensionHandler, setKeyExchangeFactories, setMacFactories, setSignatureFactories

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

Methods inherited from interface org.apache.sshd.common.AttributeStore

clearAttributes, computeAttributeIfAbsent, removeAttribute, setAttribute

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.client.ClientAuthenticationManager

setUserAuthFactoriesNames

Methods inherited from interface org.apache.sshd.client.session.ClientSession

createDynamicPortForwardingTracker, createExecChannel, createLocalPortForwardingTracker, createRemotePortForwardingTracker, createShellChannel, executeRemoteCommand, executeRemoteCommand, executeRemoteCommand

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

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

Methods inherited from interface org.apache.sshd.common.kex.extension.KexExtensionHandlerManager

getKexExtensionHandler, setKexExtensionHandler

Methods inherited from interface org.apache.sshd.common.kex.KexFactoryManager

getCipherFactories, getCipherFactoriesNameList, getCipherFactoriesNames, getCompressionFactories, getCompressionFactoriesNameList, getCompressionFactoriesNames, getKeyExchangeFactories, getMacFactories, getMacFactoriesNameList, getMacFactoriesNames, setCipherFactories, setCipherFactoriesNameList, setCipherFactoriesNames, setCipherFactoriesNames, setCompressionFactories, setCompressionFactoriesNameList, setCompressionFactoriesNames, setCompressionFactoriesNames, setKeyExchangeFactories, setMacFactories, setMacFactoriesNameList, setMacFactoriesNames, setMacFactoriesNames

Methods inherited from interface org.apache.sshd.common.auth.MutableUserHolder

setUsername

Methods inherited from interface org.apache.sshd.common.io.PacketWriter

writePacket

Methods inherited from interface org.apache.sshd.common.forward.PortForwardingEventListenerManager

addPortForwardingEventListener, getPortForwardingEventListenerProxy, removePortForwardingEventListener

Methods inherited from interface org.apache.sshd.common.forward.PortForwardingInformationProvider

getBoundLocalPortForward, getBoundRemotePortForward, getLocalForwardsBindings, getRemoteForwardsBindings, getStartedLocalPortForwards, getStartedRemotePortForwards, isLocalPortForwardingStartedForPort, isRemotePortForwardingStartedForPort

Methods inherited from interface org.apache.sshd.common.PropertyResolver

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

Methods inherited from interface org.apache.sshd.common.session.ReservedSessionMessagesManager

getReservedSessionMessagesHandler, setReservedSessionMessagesHandler

Methods inherited from interface org.apache.sshd.common.session.Session

createBuffer, createBuffer, disconnect, getAuthTimeout, getAuthTimeoutStart, getIdleTimeout, getIdleTimeoutStart, getIoSession, getKex, getLocalAddress, getRemoteAddress, getService, getTimeoutStatus, prepareBuffer, reExchangeKeys, request, resetAuthTimeout, resetIdleTimeout, resolveAttribute, sendDebugMessage, sendIgnoreMessage, setAuthenticated, writePacket

Methods inherited from interface org.apache.sshd.common.session.SessionContext

getCipherInformation, getClientKexProposals, getClientVersion, getCompressionInformation, getKexNegotiationResult, getKexState, getMacInformation, getNegotiatedKexParameter, getServerKexProposals, getServerVersion, getSessionId, isAuthenticated, isServerSession

Methods inherited from interface org.apache.sshd.common.session.SessionDisconnectHandlerManager

getSessionDisconnectHandler, setSessionDisconnectHandler

Methods inherited from interface org.apache.sshd.common.session.SessionHeartbeatController

disableSessionHeartbeat, getSessionHeartbeatInterval, getSessionHeartbeatType, setSessionHeartbeat

Methods inherited from interface org.apache.sshd.common.session.SessionListenerManager

addSessionListener, getSessionListenerProxy, removeSessionListener

Methods inherited from interface org.apache.sshd.common.signature.SignatureFactoriesManager

getSignatureFactories, getSignatureFactoriesNameList, getSignatureFactoriesNames, setSignatureFactories, setSignatureFactoriesNameList, setSignatureFactoriesNames, setSignatureFactoriesNames

Methods inherited from interface org.apache.sshd.common.session.UnknownChannelReferenceHandlerManager

getUnknownChannelReferenceHandler, resolveUnknownChannelReferenceHandler, setUnknownChannelReferenceHandler

Methods inherited from interface org.apache.sshd.common.auth.UserAuthFactoriesManager

getUserAuthFactoriesNameList, getUserAuthFactoriesNames, setUserAuthFactoriesNameList, setUserAuthFactoriesNames

Methods inherited from interface org.apache.sshd.common.auth.UsernameHolder

getUsername

Field Detail

DEFAULT_MAX_IDENTIFICATION_SIZE

private static final int DEFAULT_MAX_IDENTIFICATION_SIZE

Default setting for the maximum number of bytes to read in the initial protocol version exchange. 64kb is what OpenSSH < 8.0 read; OpenSSH 8.0 changed it to 8Mb, but that seems excessive for the purpose stated in RFC 4253. The Apache MINA sshd default in FactoryManager.DEFAULT_MAX_IDENTIFICATION_SIZE is 16kb.

See Also:

Constant Field Values

hostConfig

private org.apache.sshd.client.config.hosts.HostConfigEntry hostConfig

credentialsProvider

private CredentialsProvider credentialsProvider

proxyHandler

private volatile StatefulProxyConnector proxyHandler

authFuture

private volatile org.apache.sshd.client.future.AuthFuture authFuture

Work-around for bug 565394 / SSHD-1050; remove when using sshd 2.6.0.

earlyErrors

private java.util.List<java.lang.Throwable> earlyErrors

Records exceptions before there is an authFuture.

errorLock

private final java.lang.Object errorLock

Guards setting an earlyError and the authFuture together.

Constructor Detail

JGitClientSession

public JGitClientSession(org.apache.sshd.client.ClientFactoryManager manager,
                         org.apache.sshd.common.io.IoSession session)
                  throws java.lang.Exception

Parameters:

manager -

session -

Throws:

java.lang.Exception

Method Detail

auth

public org.apache.sshd.client.future.AuthFuture auth()
                                              throws java.io.IOException

Specified by:

auth in interface org.apache.sshd.client.session.ClientSession

Overrides:

auth in class org.apache.sshd.client.session.ClientSessionImpl

Throws:

java.io.IOException

signalAuthFailure

protected void signalAuthFailure(org.apache.sshd.client.future.AuthFuture future,
                                 java.lang.Throwable t)

Overrides:

signalAuthFailure in class org.apache.sshd.client.session.ClientSessionImpl

signalAuthFailure

private void signalAuthFailure(java.lang.Throwable t)

exceptionCaught

public void exceptionCaught(java.lang.Throwable t)

Specified by:

exceptionCaught in interface org.apache.sshd.common.session.Session

Overrides:

exceptionCaught in class org.apache.sshd.client.session.ClientSessionImpl

preClose

protected void preClose()

Overrides:

preClose in class org.apache.sshd.client.session.ClientSessionImpl

handleDisconnect

protected void handleDisconnect(int code,
                                java.lang.String msg,
                                java.lang.String lang,
                                org.apache.sshd.common.util.buffer.Buffer buffer)
                         throws java.lang.Exception

Overrides:

handleDisconnect in class org.apache.sshd.client.session.ClientSessionImpl

Throws:

java.lang.Exception

updateCurrentSessionState

protected <C extends java.util.Collection<org.apache.sshd.client.session.ClientSession.ClientSessionEvent>> C updateCurrentSessionState(C newState)

Overrides:

updateCurrentSessionState in class org.apache.sshd.client.session.ClientSessionImpl

getHostConfigEntry

public org.apache.sshd.client.config.hosts.HostConfigEntry getHostConfigEntry()

Retrieves the HostConfigEntry this session was created for.

Returns:

the HostConfigEntry, or null if none set

setHostConfigEntry

public void setHostConfigEntry(org.apache.sshd.client.config.hosts.HostConfigEntry hostConfig)

Sets the HostConfigEntry this session was created for.

Parameters:

hostConfig - the HostConfigEntry

setCredentialsProvider

public void setCredentialsProvider(CredentialsProvider provider)

Sets the CredentialsProvider for this session.

Parameters:

provider - to set

getCredentialsProvider

public CredentialsProvider getCredentialsProvider()

Retrieves the CredentialsProvider set for this session.

Returns:

the provider, or null if none is set.

setProxyHandler

public void setProxyHandler(StatefulProxyConnector handler)

Sets a StatefulProxyConnector to handle proxy connection protocols.

Parameters:

handler - to set

sendIdentification

protected org.apache.sshd.common.io.IoWriteFuture sendIdentification(java.lang.String ident)
                                                              throws java.io.IOException

Overrides:

sendIdentification in class org.apache.sshd.common.session.helpers.SessionHelper

Throws:

java.io.IOException

sendKexInit

protected byte[] sendKexInit()
                      throws java.io.IOException,
                             java.security.GeneralSecurityException

Overrides:

sendKexInit in class org.apache.sshd.common.session.helpers.AbstractSession

Throws:

java.io.IOException

java.security.GeneralSecurityException

messageReceived

public void messageReceived(org.apache.sshd.common.util.Readable buffer)
                     throws java.lang.Exception

As long as we're still setting up the proxy connection, diverts messages to the StatefulProxyConnector.

Overrides:

messageReceived in class org.apache.sshd.common.session.helpers.AbstractSession

Throws:

java.lang.Exception

checkKeys

protected void checkKeys()
                  throws org.apache.sshd.common.SshException

Overrides:

checkKeys in class org.apache.sshd.client.session.AbstractClientSession

Throws:

org.apache.sshd.common.SshException

resolveAvailableSignaturesProposal

protected java.lang.String resolveAvailableSignaturesProposal(org.apache.sshd.common.FactoryManager manager)

Overrides:

resolveAvailableSignaturesProposal in class org.apache.sshd.client.session.AbstractClientSession

removeFromList

private void removeFromList(java.util.Set<java.lang.String> current,
                            java.lang.String key,
                            java.lang.String patterns)

filteredList

private java.util.List<java.lang.String> filteredList(java.util.Set<java.lang.String> known,
                                                      java.lang.String values)

doReadIdentification

protected java.util.List<java.lang.String> doReadIdentification(org.apache.sshd.common.util.buffer.Buffer buffer,
                                                                boolean server)
                                                         throws java.io.StreamCorruptedException

Reads the RFC 4253, section 4.2 protocol version identification. The Apache MINA sshd default implementation checks for NUL bytes also in any preceding lines, whereas RFC 4253 requires such a check only for the actual identification string starting with "SSH-". Likewise, the 255 character limit exists only for the identification string, not for the preceding lines. CR-LF handling is also relaxed.

Overrides:

doReadIdentification in class org.apache.sshd.common.session.helpers.SessionHelper

Parameters:

buffer - to read from

server - whether we're an SSH server (should always be false)

Returns:

the lines read, with the server identification line last, or null if no identification line was found and more bytes are needed

Throws:

java.io.StreamCorruptedException - if the identification is malformed

See Also:

RFC 4253, section 4.2

escapeControls

private static java.lang.String escapeControls(java.lang.String s)

getAttribute

public <T> T getAttribute(org.apache.sshd.common.AttributeRepository.AttributeKey<T> key)

Specified by:

getAttribute in interface org.apache.sshd.common.AttributeRepository

Overrides:

getAttribute in class org.apache.sshd.common.session.helpers.SessionHelper

getParentPropertyResolver

public org.apache.sshd.common.PropertyResolver getParentPropertyResolver()

Specified by:

getParentPropertyResolver in interface org.apache.sshd.common.PropertyResolver

Overrides:

getParentPropertyResolver in class org.apache.sshd.common.session.helpers.SessionHelper