package org.eclipse.team.internal.ccvs.ssh; | |
/* | |
* (c) Copyright IBM Corp. 2000, 2001. | |
* All Rights Reserved. | |
*/ | |
import java.io.IOException; | |
import java.io.InputStream; | |
import java.io.OutputStream; | |
import org.eclipse.team.internal.ccvs.core.connection.CVSAuthenticationException; | |
import org.eclipse.team.ccvs.core.ICVSRepositoryLocation; | |
import org.eclipse.team.ccvs.core.IServerConnection; | |
public class SSHServerConnection implements IServerConnection { | |
// command to start remote cvs in server mode | |
private static final String INVOKE_SVR_CMD = "cvs server"; | |
private static final int DEFAULT_PORT = 22; | |
// cvs format for the repository (e.g. :extssh:user@host:/home/cvs/repo) | |
private ICVSRepositoryLocation location; | |
// password for user specified in repository location string | |
private String password; | |
// incoming from remote host | |
InputStream inputStream; | |
// outgoing to remote host | |
OutputStream outputStream; | |
// ssh client | |
Client client; | |
protected SSHServerConnection(ICVSRepositoryLocation location, String password) { | |
this.location = location; | |
this.password = password; | |
} | |
public void close() throws IOException { | |
client.disconnect(); | |
} | |
/** | |
* Returns the <code>InputStream</code> used to read data from the | |
* server. | |
*/ | |
public InputStream getInputStream() { | |
return inputStream; | |
} | |
/** | |
* Returns the <code>OutputStream</code> used to send data to the | |
* server. | |
*/ | |
public OutputStream getOutputStream() { | |
return outputStream; | |
} | |
/** | |
* Opens the connection and invokes cvs in server mode. | |
* | |
* @see Connection.open() | |
*/ | |
public void open() throws IOException, CVSAuthenticationException { | |
String hostname = location.getHost(); | |
String username = location.getUsername(); | |
int port = location.getPort(); | |
if (port == location.USE_DEFAULT_PORT) | |
port = DEFAULT_PORT; | |
// create the connection using host, username, and password | |
client = new Client(hostname, port, username, password, INVOKE_SVR_CMD, location.getTimeout()); | |
client.connect(); | |
inputStream = client.getInputStream(); | |
outputStream = client.getOutputStream(); | |
} | |
} |