Mercurial > 510Connectbot
view app/src/main/java/ch/ethz/ssh2/transport/ClientTransportManager.java @ 474:e5f8d879543f
add fg/bg color setting to global:// section of deployment.connections file
author | Carl Byington <carl@five-ten-sg.com> |
---|---|
date | Sun, 20 Oct 2019 14:08:00 -0700 |
parents | d29cce60f393 |
children |
line wrap: on
line source
package ch.ethz.ssh2.transport; import java.io.IOException; import java.net.InetSocketAddress; import java.net.Socket; import java.security.SecureRandom; import ch.ethz.ssh2.DHGexParameters; import ch.ethz.ssh2.ServerHostKeyVerifier; import ch.ethz.ssh2.crypto.CryptoWishList; /** * @version $Id: ClientTransportManager.java 151 2014-04-28 10:03:39Z dkocher@sudo.ch $ */ public class ClientTransportManager extends TransportManager { private final Socket sock; public ClientTransportManager(final Socket socket) { super(socket); this.sock = socket; } public void setTcpNoDelay(boolean state) throws IOException { sock.setTcpNoDelay(state); } public void setSoTimeout(int timeout) throws IOException { sock.setSoTimeout(timeout); } public void connect(String hostname, int port, String softwareversion, CryptoWishList cwl, ServerHostKeyVerifier verifier, DHGexParameters dhgex, int connectTimeout, SecureRandom rnd) throws IOException { // Establish the TCP connection to the SSH-2 server this.connect(hostname, port, connectTimeout); // Parse the server line and say hello - important: this information is later needed for the // key exchange (to stop man-in-the-middle attacks) - that is why we wrap it into an object // for later use. ClientServerHello csh = ClientServerHello.clientHello(softwareversion, sock.getInputStream(), sock.getOutputStream()); TransportConnection tc = new TransportConnection(sock.getInputStream(), sock.getOutputStream(), rnd); KexManager km = new ClientKexManager(this, csh, cwl, hostname, port, verifier, rnd); super.init(tc, km); km.initiateKEX(cwl, dhgex, null, null, null); this.startReceiver(); } protected void connect(String hostname, int port, int connectTimeout) throws IOException { log.debug(String.format("client transport manager connecting to %s:%d", hostname, port)); sock.connect(new InetSocketAddress(hostname, port), connectTimeout); log.debug(String.format("client transport manager connected to %s:%d", hostname, port)); } }