Package com.sshtools.client

Class TransportProtocolClient

java.lang.Object

com.sshtools.common.ssh.ExecutorOperationSupport<SshContext>

com.sshtools.synergy.ssh.TransportProtocol<SshClientContext>

com.sshtools.client.TransportProtocolClient

All Implemented Interfaces:

IdleStateListener, ProtocolEngine, SshTransport<SshClientContext>

public class TransportProtocolClient
extends TransportProtocol<SshClientContext>

The implementation of the client side of the SSH transport protocol.

Field Summary

Fields inherited from class com.sshtools.synergy.ssh.TransportProtocol

activeService, AUTH_CANCELLED_BY_USER, BY_APPLICATION, CHARSET_ENCODING, cipherCS, cipherSC, completedFirstKeyExchange, COMPRESSION_ERROR, compressionCS, compressionSC, con, CONNECTED, CONNECTION_LOST, DISCONNECTED, disconnectStarted, enableExtensionCapability, hasExtensionCapability, HOST_KEY_NOT_VERIFIABLE, HOST_NOT_ALLOWED, hostKey, ILLEGAL_USER_NAME, KEY_EXCHANGE_FAILED, keyExchangeAlgorithm, localIdentification, localkex, lock, MAC_ERROR, macCS, macSC, NEGOTIATING_PROTOCOL, NO_MORE_AUTH_METHODS_AVAILABLE, PERFORMING_KEYEXCHANGE, PROTOCOL_ERROR, PROTOCOL_VERSION_NOT_SUPPORTED, publicKey, receivedRemoteIdentification, remoteIdentification, remotekex, RESERVED, sentLocalIdentification, SERVICE_NOT_AVAILABLE, sessionIdentifier, socketConnection, SSH_MSG_EXT_INFO, SSH_MSG_SERVICE_ACCEPT, SSH_MSG_SERVICE_REQUEST, sshContext, TOO_MANY_CONNECTIONS, uuid

Fields inherited from class com.sshtools.common.ssh.ExecutorOperationSupport

CALLBACKS, EVENTS, MESSAGES_INCOMING, MESSAGES_OUTGOING

Constructor Summary

Constructors

Constructor	Description
TransportProtocolClient(SshClientContext sshContext, ConnectRequestFuture connectFuture)

Method Summary

Modifier and Type	Method	Description
protected boolean	canConnect(SocketConnection connection)
protected void	completeKeyExchange(SshKeyExchange<SshClientContext> keyExchange)
protected void	disconnected()
Service	getActiveService()
protected String	getExtensionNegotiationString()
String	getName()
protected void	initializeKeyExchange(SshKeyExchange<SshClientContext> keyExchange, boolean firstPacketFollows, boolean useFirstPacket)
protected boolean	isExtensionNegotiationSupported()
protected boolean	isServerMode()
protected void	onConnected()
protected void	onDisconnected()
protected void	onKeyExchangeInit()
protected void	onNewKeysReceived()
protected void	onNewKeysSent()
boolean	onSocketRead(ByteBuffer incomingData)
protected boolean	processTransportMessage(int msgid, byte[] msg)
protected String	selectNegotiatedComponent(String remotelist, String locallist)
void	setActiveService(Service service)
void	startService(Service service)

Methods inherited from class com.sshtools.synergy.ssh.TransportProtocol

addEventListener, canSendKeyExchangeInit, disconnect, generateNewKeysClientIn, generateNewKeysClientOut, generateNewKeysServerIn, generateNewKeysServerOut, getAuthenticatedFuture, getBytes, getCipherCS, getCipherSC, getCompressionCS, getCompressionSC, getConnectFuture, getConnection, getContext, getDisconnectFuture, getExecutor, getHostKey, getHostKeyAlgorithm, getHostKeyInUse, getKeyExchangeAlgorithm, getKeyExchangeInUse, getLocalAddress, getLocalIdentification, getLocalPort, getMacCS, getMacSC, getQueueSizes, getRemoteAddress, getRemoteCiphersCS, getRemoteCiphersSC, getRemoteCompressionsCS, getRemoteCompressionsSC, getRemoteIdentification, getRemoteKeyExchanges, getRemoteMacsCS, getRemoteMacsSC, getRemotePort, getRemotePublicKeys, getRND, getSessionKey, getSocketConnection, getSshContext, getState, getUUID, hasCompletedKeyExchange, idle, isConnected, isDisonnecting, isSelectorThread, keyExchangeInitialized, kill, onKeyExchangeComplete, onRemoteIdentificationReceived, onSocketClose, onSocketConnect, onSocketWrite, postMessage, postMessage, processMessage, processNegotiationString, registerIdleStateListener, removeIdleStateListener, resetIdleState, sendNewKeys, startBinaryProtocol, transferState, wantsToWrite

Methods inherited from class com.sshtools.common.ssh.ExecutorOperationSupport

addIncomingTask, addOutgoingTask, addTask, cleanupOperations

Methods inherited from class java.lang.Object

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

Constructor Details

TransportProtocolClient

public TransportProtocolClient(SshClientContext sshContext,
 ConnectRequestFuture connectFuture)
                        throws LicenseException

Throws:

LicenseException

Method Details

canConnect

protected boolean canConnect(SocketConnection connection)

Specified by:

canConnect in class TransportProtocol<SshClientContext>

onSocketRead

public boolean onSocketRead(ByteBuffer incomingData)

Specified by:

onSocketRead in interface ProtocolEngine

Overrides:

onSocketRead in class TransportProtocol<SshClientContext>

initializeKeyExchange

protected void initializeKeyExchange(SshKeyExchange<SshClientContext> keyExchange,
 boolean firstPacketFollows,
 boolean useFirstPacket)
                              throws IOException,
SshException

Specified by:

initializeKeyExchange in class TransportProtocol<SshClientContext>

Throws:

IOException

SshException

onKeyExchangeInit

protected void onKeyExchangeInit()

Specified by:

onKeyExchangeInit in class TransportProtocol<SshClientContext>

completeKeyExchange

protected void completeKeyExchange(SshKeyExchange<SshClientContext> keyExchange)

Overrides:

completeKeyExchange in class TransportProtocol<SshClientContext>

onNewKeysReceived

protected void onNewKeysReceived()

Specified by:

onNewKeysReceived in class TransportProtocol<SshClientContext>

onNewKeysSent

protected void onNewKeysSent()

Specified by:

onNewKeysSent in class TransportProtocol<SshClientContext>

selectNegotiatedComponent

protected String selectNegotiatedComponent(String remotelist,
 String locallist)
                                    throws IOException

Overrides:

selectNegotiatedComponent in class TransportProtocol<SshClientContext>

Throws:

IOException

processTransportMessage

protected boolean processTransportMessage(int msgid,
 byte[] msg)
                                   throws IOException,
SshException

Specified by:

processTransportMessage in class TransportProtocol<SshClientContext>

Throws:

IOException

SshException

setActiveService

public void setActiveService(Service service)

getActiveService

public Service getActiveService()

startService

public void startService(Service service)

disconnected

protected void disconnected()

Specified by:

disconnected in class TransportProtocol<SshClientContext>

onConnected

protected void onConnected()

Specified by:

onConnected in class TransportProtocol<SshClientContext>

onDisconnected

protected void onDisconnected()

Specified by:

onDisconnected in class TransportProtocol<SshClientContext>

getName

public String getName()

getExtensionNegotiationString

protected String getExtensionNegotiationString()

Specified by:

getExtensionNegotiationString in class TransportProtocol<SshClientContext>

isExtensionNegotiationSupported

protected boolean isExtensionNegotiationSupported()

Specified by:

isExtensionNegotiationSupported in class TransportProtocol<SshClientContext>

isServerMode

protected boolean isServerMode()

Specified by:

isServerMode in class TransportProtocol<SshClientContext>