Class TransportManager

java.lang.Object

com.trilead.ssh2.transport.TransportManager

public class TransportManager
extends Object

TransportManager.

Version:

$Id: TransportManager.java,v 1.2 2008/04/01 12:38:09 cplattne Exp $

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	TransportManager.AsynchronousWorker
(package private) class	TransportManager.HandlerEntry

Field Summary

Fields

Modifier and Type	Field	Description
private final Vector	asynchronousQueue
private Thread	asynchronousThread
(package private) Vector	connectionMonitors
(package private) final Object	connectionSemaphore
(package private) boolean	flagKexOngoing
(package private) String	hostname
(package private) KexManager	km
private static final Logger	log
static final int	MAX_PACKET_SIZE	Advertised maximum SSH packet size that the other side can send to us.
(package private) Vector	messageHandlers
(package private) boolean	monitorsWereInformed
(package private) int	port
(package private) Throwable	reasonClosedCause
(package private) Thread	receiveThread
(package private) final Socket	sock
private final String	sourceAddress
(package private) TransportConnection	tc
private ClientServerHello	versions

Constructor Summary

Constructors

Constructor	Description
TransportManager(String host, int port)
TransportManager(String host, int port, String sourceAddress)

Method Summary

Modifier and Type	Method	Description
void	changeRecvCipher(BlockCipher bc, MAC mac)
void	changeSendCipher(BlockCipher bc, MAC mac)
void	close(Throwable cause, boolean useDisconnectPacket)
private InetAddress	createInetAddress(String host)	There were reports that there are JDKs which use the resolver even though one supplies a dotted IP address in the Socket constructor.
private void	ensureConnected()
private void	establishConnection(ProxyData proxyData, int connectTimeout, int readTimeout)
void	forceKeyExchange(CryptoWishList cwl, DHGexParameters dhgex)
ConnectionInfo	getConnectionInfo(int kexNumber)
int	getPacketOverheadEstimate()
Throwable	getReasonClosedCause()	If the socket connection is lost (either by this side closing down or the other side closing down),
byte[]	getSessionIdentifier()
ClientServerHello	getVersionInfo()
void	initialize(CryptoWishList cwl, ServerHostKeyVerifier verifier, DHGexParameters dhgex, int connectTimeout, int readTimeout, SecureRandom rnd, ProxyData proxyData)
void	initialize(CryptoWishList cwl, ServerHostKeyVerifier verifier, DHGexParameters dhgex, int connectTimeout, SecureRandom rnd, ProxyData proxyData)
boolean	isConnectionClosed()
void	kexFinished()
private InetAddress	parseIPv4Address(String host)
void	receiveLoop()
void	registerMessageHandler(MessageHandler mh, int low, int high)
void	removeMessageHandler(MessageHandler mh, int low, int high)
void	sendAsynchronousMessage(byte[] msg)
void	sendKexMessage(byte[] msg)
void	sendMessage(byte[] msg)
void	setConnectionMonitors(Vector monitors)
void	setSoTimeout(int timeout)
void	setTcpNoDelay(boolean state)

Methods inherited from class Object

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

Field Details

log

private static final Logger log

asynchronousQueue

private final Vector asynchronousQueue

asynchronousThread

private Thread asynchronousThread

sourceAddress

private final String sourceAddress

hostname

String hostname

port

int port

sock

final Socket sock

connectionSemaphore

final Object connectionSemaphore

flagKexOngoing

boolean flagKexOngoing

reasonClosedCause

Throwable reasonClosedCause

tc

TransportConnection tc

km

KexManager km

messageHandlers

Vector messageHandlers

receiveThread

Thread receiveThread

connectionMonitors

Vector connectionMonitors

monitorsWereInformed

boolean monitorsWereInformed

versions

private ClientServerHello versions

MAX_PACKET_SIZE

public static final int MAX_PACKET_SIZE

Advertised maximum SSH packet size that the other side can send to us.

Constructor Details

TransportManager

public TransportManager(String host,
 int port)
                 throws IOException

Throws:

IOException

TransportManager

public TransportManager(String host,
 int port,
 String sourceAddress)
                 throws IOException

Throws:

IOException

Method Details

createInetAddress

private InetAddress createInetAddress(String host)
                               throws UnknownHostException

There were reports that there are JDKs which use the resolver even though one supplies a dotted IP address in the Socket constructor. That is why we try to generate the InetAdress "by hand".

Parameters:

host -

Returns:

the InetAddress

Throws:

UnknownHostException

parseIPv4Address

private InetAddress parseIPv4Address(String host)
                              throws UnknownHostException

Throws:

UnknownHostException

getPacketOverheadEstimate

public int getPacketOverheadEstimate()

setTcpNoDelay

public void setTcpNoDelay(boolean state)
                   throws IOException

Throws:

IOException

setSoTimeout

public void setSoTimeout(int timeout)
                  throws IOException

Throws:

IOException

getConnectionInfo

public ConnectionInfo getConnectionInfo(int kexNumber)
                                 throws IOException

Throws:

IOException

getVersionInfo

public ClientServerHello getVersionInfo()

getReasonClosedCause

public Throwable getReasonClosedCause()

If the socket connection is lost (either by this side closing down or the other side closing down),

Returns:

a non-null object indicating the cause of the connection loss.

isConnectionClosed

public boolean isConnectionClosed()

getSessionIdentifier

public byte[] getSessionIdentifier()

close

public void close(Throwable cause,
 boolean useDisconnectPacket)

establishConnection

private void establishConnection(ProxyData proxyData,
 int connectTimeout,
 int readTimeout)
                          throws IOException

Throws:

IOException

initialize

public void initialize(CryptoWishList cwl,
 ServerHostKeyVerifier verifier,
 DHGexParameters dhgex,
 int connectTimeout,
 SecureRandom rnd,
 ProxyData proxyData)
                throws IOException

Throws:

IOException

initialize

public void initialize(CryptoWishList cwl,
 ServerHostKeyVerifier verifier,
 DHGexParameters dhgex,
 int connectTimeout,
 int readTimeout,
 SecureRandom rnd,
 ProxyData proxyData)
                throws IOException

Throws:

IOException

registerMessageHandler

public void registerMessageHandler(MessageHandler mh,
 int low,
 int high)

removeMessageHandler

public void removeMessageHandler(MessageHandler mh,
 int low,
 int high)

sendKexMessage

public void sendKexMessage(byte[] msg)
                    throws IOException

Throws:

IOException

ensureConnected

private void ensureConnected()
                      throws IOException

Throws:

IOException

kexFinished

public void kexFinished()
                 throws IOException

Throws:

IOException

forceKeyExchange

public void forceKeyExchange(CryptoWishList cwl,
 DHGexParameters dhgex)
                      throws IOException

Throws:

IOException

changeRecvCipher

public void changeRecvCipher(BlockCipher bc,
 MAC mac)

changeSendCipher

public void changeSendCipher(BlockCipher bc,
 MAC mac)

sendAsynchronousMessage

public void sendAsynchronousMessage(byte[] msg)
                             throws IOException

Throws:

IOException

setConnectionMonitors

public void setConnectionMonitors(Vector monitors)

sendMessage

public void sendMessage(byte[] msg)
                 throws IOException

Throws:

IOException

receiveLoop

public void receiveLoop()
                 throws IOException

Throws:

IOException