import ch.ethz.ssh2.ConnectionInfo; //导入依赖的package包/类
public ConnectionInfo getOrWaitForConnectionInfo(int minKexCount) throws IOException {
    synchronized (accessLock) {
        while (true) {
            if ((lastConnInfo != null) && (lastConnInfo.keyExchangeCounter >= minKexCount))
                return lastConnInfo;

            if (connectionClosed)
                throw (IOException) new IOException("Key exchange was not finished, connection is closed.")
                        .initCause(tm.getReasonClosedCause());

            try {
                accessLock.wait();
            } catch (InterruptedException e) {
            }
        }
    }
}
 

import ch.ethz.ssh2.ConnectionInfo; //导入依赖的package包/类
public ConnectionInfo getOrWaitForConnectionInfo(int minKexCount) throws IOException
{
	synchronized (accessLock)
	{
		while (true)
		{
			if ((lastConnInfo != null) && (lastConnInfo.keyExchangeCounter >= minKexCount))
				return lastConnInfo;

			if (connectionClosed)
				throw (IOException) new IOException("Key exchange was not finished, connection is closed.")
						.initCause(tm.getReasonClosedCause());

			try
			{
				accessLock.wait();
			}
			catch (InterruptedException e)
			{
				Thread.currentThread().interrupt();
			}
		}
	}
}
 

import ch.ethz.ssh2.ConnectionInfo; //导入依赖的package包/类
public ConnectionInfo getOrWaitForConnectionInfo(int minKexCount) throws IOException
{
	synchronized (accessLock)
	{
		while (true)
		{
			if ((lastConnInfo != null) && (lastConnInfo.keyExchangeCounter >= minKexCount))
				return lastConnInfo;

			if (connectionClosed)
				throw (IOException) new IOException("Key exchange was not finished, connection is closed.")
						.initCause(tm.getReasonClosedCause());

			try
			{
				accessLock.wait();
			}
			catch (InterruptedException e)
			{
			}
		}
	}
}
 

import ch.ethz.ssh2.ConnectionInfo; //导入依赖的package包/类
@Override
public String getServerHostKey(String host, int port, Algorithm algorithm) throws Throwable {
    ch.ethz.ssh2.Connection conn = new ch.ethz.ssh2.Connection(host, port);
    conn.setServerHostKeyAlgorithms(new String[] { algorithm.signature() });
    String hostKey = null;
    try {
        ConnectionInfo info = conn.connect();
        hostKey = new String(Base64.encode(info.serverHostKey), "UTF-8");
    } finally {
        conn.close();
    }
    return hostKey;
}
 

import ch.ethz.ssh2.ConnectionInfo; //导入依赖的package包/类
protected ConnectionInfo connect() throws IOException {
    return conn.connect(
            new CPositiveKeyVerifier(),iTo,iKexTo);
}
 

import ch.ethz.ssh2.ConnectionInfo; //导入依赖的package包/类
public ConnectionInfo getConnectionInfo(int kexNumber) throws IOException
{
	return km.getOrWaitForConnectionInfo(kexNumber);
}