ch.ethz.ssh2.transport

Class TransportManager

java.lang.Object

ch.ethz.ssh2.transport.TransportManager

Direct Known Subclasses:

ClientTransportManager, ServerTransportManager

public abstract class TransportManager
extends Object

TransportManager.

Version:

$Id: TransportManager.java 102 2014-04-10 13:42:05Z dkocher@sudo.ch $

Author:

Christian Plattner

Constructor Summary

Constructors

Constructor and Description
TransportManager()

Method Summary

Methods

Modifier and Type	Method and Description
void	changeRecvCipher(BlockCipher bc, MAC mac)
void	changeSendCipher(BlockCipher bc, MAC mac)
void	close(Socket sock, Throwable cause, boolean useDisconnectPacket)
void	close(Throwable cause)
abstract void	close(Throwable cause, boolean useDisconnectPacket)
void	forceKeyExchange(CryptoWishList cwl, DHGexParameters dhgex, DSAPrivateKey dsa, RSAPrivateKey rsa)
ConnectionInfo	getConnectionInfo(int kexNumber)
int	getPacketOverheadEstimate()
Throwable	getReasonClosedCause()
byte[]	getSessionIdentifier()
protected void	init(TransportConnection tc, KexManager km)
void	kexFinished()
void	receiveLoop()
void	registerMessageHandler(MessageHandler mh, int low, int high)
void	removeMessageHandler(MessageHandler mh, int low, int high)
void	sendAsynchronousMessage(byte[] msg)
void	sendAsynchronousMessage(byte[] msg, Runnable run)
void	sendKexMessage(byte[] msg)
void	sendMessage(byte[] msg) Send a message but ensure that all queued messages are being sent first.
void	sendMessageImmediate(byte[] msg) Send message, ignore queued async messages that have not been delivered yet.
void	setConnectionMonitors(List<ConnectionMonitor> monitors)
protected void	startReceiver()

Methods inherited from class java.lang.Object

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

Constructor Detail

TransportManager

public TransportManager()

Method Detail

init

protected void init(TransportConnection tc,
        KexManager km)

getPacketOverheadEstimate

public int getPacketOverheadEstimate()

getConnectionInfo

public ConnectionInfo getConnectionInfo(int kexNumber)
                                 throws IOException

Throws:

IOException

getReasonClosedCause

public Throwable getReasonClosedCause()

getSessionIdentifier

public byte[] getSessionIdentifier()

close

public void close(Throwable cause)

close

public abstract void close(Throwable cause,
         boolean useDisconnectPacket)

close

public void close(Socket sock,
         Throwable cause,
         boolean useDisconnectPacket)

startReceiver

protected void startReceiver()
                      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

kexFinished

public void kexFinished()
                 throws IOException

Throws:

IOException

forceKeyExchange

public void forceKeyExchange(CryptoWishList cwl,
                    DHGexParameters dhgex,
                    DSAPrivateKey dsa,
                    RSAPrivateKey rsa)
                      throws IOException

Parameters:

cwl -

dhgex -

dsa - may be null if this is a client connection

rsa - may be null if this is a client connection

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

sendAsynchronousMessage

public void sendAsynchronousMessage(byte[] msg,
                           Runnable run)
                             throws IOException

Throws:

IOException

setConnectionMonitors

public void setConnectionMonitors(List<ConnectionMonitor> monitors)

sendMessage

public void sendMessage(byte[] msg)
                 throws IOException

Send a message but ensure that all queued messages are being sent first.

Parameters:

msg -

Throws:

IOException

sendMessageImmediate

public void sendMessageImmediate(byte[] msg)
                          throws IOException

Send message, ignore queued async messages that have not been delivered yet. Will be called directly from the asynchronousThread thread.

Parameters:

msg -

Throws:

IOException

receiveLoop

public void receiveLoop()
                 throws IOException

Throws:

IOException