Class KexManager

java.lang.Object

com.trilead.ssh2.transport.KexManager

All Implemented Interfaces:

MessageHandler

public class KexManager
extends Object
implements MessageHandler

KexManager.

Version:

$Id: KexManager.java,v 1.1 2007/10/15 12:49:56 cplattne Exp $

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final Object	accessLock
(package private) boolean	connectionClosed
(package private) ClientServerHello	csh
private static final List<String>	DEFAULT_KEY_ALGORITHMS
(package private) final String	hostname
(package private) boolean	ignore_next_kex_packet
(package private) int	kexCount
(package private) KeyMaterial	km
(package private) KexState	kxs
(package private) ConnectionInfo	lastConnInfo
private static final Logger	log
(package private) CryptoWishList	nextKEXcryptoWishList
(package private) DHGexParameters	nextKEXdhgexParameters
(package private) final int	port
(package private) final SecureRandom	rnd
(package private) byte[]	sessionId
(package private) final TransportManager	tm
(package private) ServerHostKeyVerifier	verifier

Constructor Summary

Constructors

Constructor	Description
KexManager(TransportManager tm, ClientServerHello csh, CryptoWishList initialCwl, String hostname, int port, ServerHostKeyVerifier keyVerifier, SecureRandom rnd)

Method Summary

Modifier and Type	Method	Description
private static List<String>	buildDefaultKeyAlgorithms()
static void	checkKexAlgorithmList(String[] algos)
static void	checkServerHostkeyAlgorithmsList(String[] algos)
private boolean	compareFirstOfNameList(String[] a, String[] b)
private boolean	establishKeyMaterial()
private void	finishKex()
static String[]	getDefaultKexAlgorithmList()
static String[]	getDefaultServerHostkeyAlgorithmList()
private String	getFirstMatch(String[] client, String[] server)
ConnectionInfo	getOrWaitForConnectionInfo(int minKexCount)
void	handleEndMessage(Throwable cause)	Called to inform that no more messages will be delivered.
void	handleMessage(byte[] msg, int msglen)	Handle message.
void	initiateKEX(CryptoWishList cwl, DHGexParameters dhgex)
private boolean	isGuessOK(KexParameters cpar, KexParameters spar)
private NegotiatedParameters	mergeKexParameters(KexParameters client, KexParameters server)
private boolean	verifySignature(byte[] sig, byte[] hostkey)

Methods inherited from class Object

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

Field Details

log

private static final Logger log

DEFAULT_KEY_ALGORITHMS

private static final List<String> DEFAULT_KEY_ALGORITHMS

kxs

KexState kxs

kexCount

int kexCount

km

KeyMaterial km

sessionId

byte[] sessionId

csh

ClientServerHello csh

accessLock

final Object accessLock

lastConnInfo

ConnectionInfo lastConnInfo

connectionClosed

boolean connectionClosed

ignore_next_kex_packet

boolean ignore_next_kex_packet

tm

final TransportManager tm

nextKEXcryptoWishList

CryptoWishList nextKEXcryptoWishList

nextKEXdhgexParameters

DHGexParameters nextKEXdhgexParameters

verifier

ServerHostKeyVerifier verifier

hostname

final String hostname

port

final int port

rnd

final SecureRandom rnd

Constructor Details

KexManager

public KexManager(TransportManager tm,
 ClientServerHello csh,
 CryptoWishList initialCwl,
 String hostname,
 int port,
 ServerHostKeyVerifier keyVerifier,
 SecureRandom rnd)

Method Details

getOrWaitForConnectionInfo

public ConnectionInfo getOrWaitForConnectionInfo(int minKexCount)
                                          throws IOException

Throws:

IOException

getFirstMatch

private String getFirstMatch(String[] client,
 String[] server)
                      throws NegotiateException

Throws:

NegotiateException

compareFirstOfNameList

private boolean compareFirstOfNameList(String[] a,
 String[] b)

isGuessOK

private boolean isGuessOK(KexParameters cpar,
 KexParameters spar)

mergeKexParameters

private NegotiatedParameters mergeKexParameters(KexParameters client,
 KexParameters server)

initiateKEX

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

Throws:

IOException

establishKeyMaterial

private boolean establishKeyMaterial()

finishKex

private void finishKex()
                throws IOException

Throws:

IOException

getDefaultServerHostkeyAlgorithmList

public static String[] getDefaultServerHostkeyAlgorithmList()

buildDefaultKeyAlgorithms

private static List<String> buildDefaultKeyAlgorithms()

checkServerHostkeyAlgorithmsList

public static void checkServerHostkeyAlgorithmsList(String[] algos)

getDefaultKexAlgorithmList

public static String[] getDefaultKexAlgorithmList()

checkKexAlgorithmList

public static void checkKexAlgorithmList(String[] algos)

verifySignature

private boolean verifySignature(byte[] sig,
 byte[] hostkey)
                         throws IOException

Throws:

IOException

handleMessage

public void handleMessage(byte[] msg,
 int msglen)
                   throws IOException

Description copied from interface: MessageHandler

Handle message.

Specified by:

handleMessage in interface MessageHandler

Parameters:

msg - the msg

msglen - the msglen

Throws:

IOException - the io exception

handleEndMessage

public void handleEndMessage(Throwable cause)
                      throws IOException

Description copied from interface: MessageHandler

Called to inform that no more messages will be delivered.

Specified by:

handleEndMessage in interface MessageHandler

Parameters:

cause - For diagnosis, the reason that caused the transport to close down.

Throws:

IOException - the io exception