Skip to main content
summaryrefslogtreecommitdiffstats
path: root/bundles/org.eclipse.team.cvs.ssh2/src/org/eclipse/team/ccvs/ssh2/PServerSSH2ServerConnection.java
diff options
context:
space:
mode:
Diffstat (limited to 'bundles/org.eclipse.team.cvs.ssh2/src/org/eclipse/team/ccvs/ssh2/PServerSSH2ServerConnection.java')
-rw-r--r--bundles/org.eclipse.team.cvs.ssh2/src/org/eclipse/team/ccvs/ssh2/PServerSSH2ServerConnection.java359
1 files changed, 123 insertions, 236 deletions
diff --git a/bundles/org.eclipse.team.cvs.ssh2/src/org/eclipse/team/ccvs/ssh2/PServerSSH2ServerConnection.java b/bundles/org.eclipse.team.cvs.ssh2/src/org/eclipse/team/ccvs/ssh2/PServerSSH2ServerConnection.java
index 9b31d5b9e..8acbbd131 100644
--- a/bundles/org.eclipse.team.cvs.ssh2/src/org/eclipse/team/ccvs/ssh2/PServerSSH2ServerConnection.java
+++ b/bundles/org.eclipse.team.cvs.ssh2/src/org/eclipse/team/ccvs/ssh2/PServerSSH2ServerConnection.java
@@ -1,258 +1,145 @@
/* -*-mode:java; c-basic-offset:2; -*- */
-/**********************************************************************
-Copyright (c) 2003, Atsuhiko Yamanaka, JCraft,Inc. and others.
-All rights reserved. This program and the accompanying materials
-are made available under the terms of the Common Public License v1.0
-which accompanies this distribution, and is available at
-http://www.eclipse.org/legal/cpl-v10.html
-
-Contributors:
- Atsuhiko Yamanaka, JCraft,Inc. - initial API and implementation.
-**********************************************************************/
+/*******************************************************************************
+ * Copyright (c) 2003, Atsuhiko Yamanaka, JCraft,Inc. and others. All rights
+ * reserved. This program and the accompanying materials are made available
+ * under the terms of the Common Public License v1.0 which accompanies this
+ * distribution, and is available at http://www.eclipse.org/legal/cpl-v10.html
+ *
+ * Contributors: Atsuhiko Yamanaka, JCraft,Inc. - initial API and
+ * implementation.
+ ******************************************************************************/
package org.eclipse.team.ccvs.ssh2;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.OutputStream;
-
+import java.io.*;
import java.util.Properties;
import org.eclipse.core.runtime.IProgressMonitor;
-import org.eclipse.team.internal.ccvs.core.ICVSRepositoryLocation;
-import org.eclipse.team.internal.ccvs.core.IServerConnection;
+import org.eclipse.team.internal.ccvs.core.*;
import org.eclipse.team.internal.ccvs.core.connection.CVSAuthenticationException;
-
import org.eclipse.team.internal.ccvs.core.connection.CVSRepositoryLocation;
-import org.eclipse.team.internal.ccvs.core.IConnectionMethod;
-
-import org.eclipse.jface.dialogs.Dialog;
-import org.eclipse.swt.widgets.Display;
-import org.eclipse.swt.widgets.Shell;
-
-import org.eclipse.swt.SWT;
-import org.eclipse.swt.widgets.MessageBox;
-
-import java.io.PipedInputStream;
-import java.io.PipedOutputStream;
import com.jcraft.jsch.*;
public class PServerSSH2ServerConnection implements IServerConnection {
-
- private ICVSRepositoryLocation location;
- private String password;
-
- private Session session;
- private Channel channel;
-
- private static int localport=2402;
-
- private IServerConnection psc=null;
- protected PServerSSH2ServerConnection(ICVSRepositoryLocation location,
- String password) {
- this.location=location;
- this.password=password;
- }
+ private ICVSRepositoryLocation location;
+ private String password;
- public void close() throws IOException {
- psc.close();
- }
+ private Session session;
+ private Channel channel;
- public InputStream getInputStream() { return psc.getInputStream(); }
- public OutputStream getOutputStream() { return psc.getOutputStream(); }
+ private static int localport = 2402;
- public void open(IProgressMonitor monitor) throws IOException,
- CVSAuthenticationException {
- monitor.subTask("PServerSSH2ServerConnection.open");
- monitor.worked(1);
- String cvs_root=location.getRootDirectory();
- int cvs_port=location.getPort();
- if(cvs_port==0) cvs_port=2401;
- String cvs_host=location.getHost();
- String ssh_host=cvs_host;
- String ssh_user=location.getUsername();
+ private IServerConnection psc = null;
- String host=cvs_host;
- if(host.indexOf('@')!=-1){
- cvs_host=host.substring(host.lastIndexOf('@')+1);
- host=host.substring(0, host.lastIndexOf('@'));
- if(host.indexOf('@')!=-1){
- ssh_host=host.substring(host.lastIndexOf('@')+1);
- if(ssh_host.length()==0)ssh_host=cvs_host;
- ssh_user=host.substring(0, host.lastIndexOf('@'));
- }
- else{
- ssh_host=host;
- }
- }
-
- int ssh_port=0;
- if(ssh_host.indexOf('#')!=-1){
- try{
- ssh_port=Integer.parseInt(ssh_host.substring(ssh_host.lastIndexOf('#')+1));
- ssh_host=ssh_host.substring(0, ssh_host.lastIndexOf('#'));
- }
- catch(Exception e){
- }
- }
-
- int lport=cvs_port;
- String rhost=(cvs_host.equals(ssh_host) ? "localhost" : cvs_host);
- int rport=cvs_port;
+ protected PServerSSH2ServerConnection(ICVSRepositoryLocation location, String password) {
+ this.location = location;
+ this.password = password;
+ }
- // ssh -L lport:rhost:rport ssh_user@ssh_host
- int retry=1;
- while(true){
- try{
- session=JSchSession.getSession(ssh_user, "", ssh_host, ssh_port, monitor);
- String[] list=session.getPortForwardingL();
- String name=":"+rhost+":"+rport;
- boolean done=false;
- for(int i=0; i<list.length; i++){
- if(list[i].endsWith(name)) {
- try{
- String foo=list[i].substring(0, list[i].indexOf(':'));
- lport=Integer.parseInt(foo);
- }
- catch(Exception ee){
- }
- done=true;
- break;
- }
+ public void close() throws IOException {
+ psc.close();
}
- if(!done){
- lport=localport++;
- session.setPortForwardingL(lport, rhost, rport);
+
+ public InputStream getInputStream() {
+ return psc.getInputStream();
}
- }
- catch(JSchException ee){
- if(!session.isConnected()){
- //System.out.println("sesssion is down");
- retry--;
- if(retry<0){
- throw new CVSAuthenticationException(ee.toString());
- }
- continue;
+ public OutputStream getOutputStream() {
+ return psc.getOutputStream();
}
- throw new CVSAuthenticationException(ee.toString());
- }
- break;
- }
-
- // CVSROOT=":pserver:localhost:"+lport+""cvs_root
- try{
- Properties prop=new Properties();
- prop.put("connection", "pserver");
- prop.put("user", location.getUsername());
- prop.put("password", password);
- prop.put("host", "localhost");
- prop.put("port", Integer.toString(lport));
- prop.put("root", cvs_root);
- CVSRepositoryLocation cvsrl=CVSRepositoryLocation.fromProperties(prop);
-
- IConnectionMethod method=cvsrl.getMethod();
- psc=method.createConnection(cvsrl, password);
- }
- catch(Exception e){
- throw new CVSAuthenticationException(e.toString());
- }
- psc.open(monitor);
- }
-
- class MyUserInfo implements UserInfo{
- private String username;
- private String password;
- private String passphrase;
- MyUserInfo(String username){
- this.username=username;
- }
- public String getPassword(){ return password; }
- public String getPassphrase(){ return passphrase; }
- public boolean promptYesNo(String str){
- YesNoPrompt prompt=new YesNoPrompt(str);
- Display.getDefault().syncExec(prompt);
- return prompt.getResult()==SWT.YES;
- }
- public boolean promptPassphrase(String message){
- PassphrasePrompt prompt=new PassphrasePrompt(message);
- Display.getDefault().syncExec(prompt);
- String _passphrase=prompt.getPassphrase();
- if(_passphrase!=null)passphrase=_passphrase;
- return _passphrase!=null;
- }
- public boolean promptPassword(String message){
- PasswordPrompt prompt=new PasswordPrompt(message);
- Display.getDefault().syncExec(prompt);
- String _password=prompt.getPassword();
- if(_password!=null)password=_password;
- return _password!=null;
- }
- public void showMessage(final String foo){
- final Display display=Display.getCurrent();
- display.syncExec(new Runnable(){
- public void run(){
- Shell shell=new Shell(display);
- MessageBox box=new MessageBox(shell,SWT.OK);
- box.setMessage(foo);
- box.open();
- shell.dispose();
- }
- });
- }
-
- private class YesNoPrompt implements Runnable{
- private String prompt;
- private int result;
- YesNoPrompt(String prompt){
- this.prompt=prompt;
- }
- public void run(){
- Display display=Display.getCurrent();
- Shell shell=new Shell(display);
- MessageBox box=new MessageBox(shell,SWT.YES|SWT.NO);
- box.setMessage(prompt);
- result=box.open();
- shell.dispose();
- }
- public int getResult(){ return result; }
- }
- private class PasswordPrompt implements Runnable{
- private String message;
- private String password;
- PasswordPrompt(String message){
- this.message=message;
- }
- public void run(){
- Display display=Display.getCurrent();
- Shell shell=new Shell(display);
- PasswordDialog dialog=new PasswordDialog(shell, message);
- dialog.open();
- shell.dispose();
- password=dialog.getPassword();
- }
- public String getPassword(){
- return password;
- }
- }
- private class PassphrasePrompt implements Runnable{
- private String message;
- private String passphrase;
- PassphrasePrompt(String message){
- this.message=message;
- }
- public void run(){
- Display display=Display.getCurrent();
- Shell shell=new Shell(display);
- PassphraseDialog dialog=new PassphraseDialog(shell, message);
- dialog.open();
- shell.dispose();
- passphrase=dialog.getPassphrase();
- }
- public String getPassphrase(){
- return passphrase;
- }
- }
- }
-}
+ public void open(IProgressMonitor monitor) throws IOException, CVSAuthenticationException {
+ monitor.subTask("PServerSSH2ServerConnection.open");
+ monitor.worked(1);
+ String cvs_root = location.getRootDirectory();
+ int cvs_port = location.getPort();
+ if (cvs_port == 0)
+ cvs_port = 2401;
+ String cvs_host = location.getHost();
+ String ssh_host = cvs_host;
+ String ssh_user = location.getUsername();
+
+ String host = cvs_host;
+ if (host.indexOf('@') != -1) {
+ cvs_host = host.substring(host.lastIndexOf('@') + 1);
+ host = host.substring(0, host.lastIndexOf('@'));
+ if (host.indexOf('@') != -1) {
+ ssh_host = host.substring(host.lastIndexOf('@') + 1);
+ if (ssh_host.length() == 0)
+ ssh_host = cvs_host;
+ ssh_user = host.substring(0, host.lastIndexOf('@'));
+ } else {
+ ssh_host = host;
+ }
+ }
+
+ int ssh_port = 0;
+ if (ssh_host.indexOf('#') != -1) {
+ try {
+ ssh_port = Integer.parseInt(ssh_host.substring(ssh_host.lastIndexOf('#') + 1));
+ ssh_host = ssh_host.substring(0, ssh_host.lastIndexOf('#'));
+ } catch (Exception e) {
+ }
+ }
+
+ int lport = cvs_port;
+ String rhost = (cvs_host.equals(ssh_host) ? "localhost" : cvs_host);
+ int rport = cvs_port;
+
+ // ssh -L lport:rhost:rport ssh_user@ssh_host
+ int retry = 1;
+ while (true) {
+ try {
+ session = JSchSession.getSession(location, ssh_user, "", ssh_host, ssh_port, monitor);
+ String[] list = session.getPortForwardingL();
+ String name = ":" + rhost + ":" + rport;
+ boolean done = false;
+ for (int i = 0; i < list.length; i++) {
+ if (list[i].endsWith(name)) {
+ try {
+ String foo = list[i].substring(0, list[i].indexOf(':'));
+ lport = Integer.parseInt(foo);
+ } catch (Exception ee) {
+ }
+ done = true;
+ break;
+ }
+ }
+ if (!done) {
+ lport = localport++;
+ session.setPortForwardingL(lport, rhost, rport);
+ }
+ } catch (JSchException ee) {
+ if (!session.isConnected()) {
+ //System.out.println("sesssion is down");
+ retry--;
+ if (retry < 0) {
+ throw new CVSAuthenticationException(ee.toString());
+ }
+ continue;
+ }
+ throw new CVSAuthenticationException(ee.toString());
+ }
+ break;
+ }
+
+ // CVSROOT=":pserver:localhost:"+lport+""cvs_root
+ try {
+ Properties prop = new Properties();
+ prop.put("connection", "pserver");
+ prop.put("user", location.getUsername());
+ prop.put("password", password);
+ prop.put("host", "localhost");
+ prop.put("port", Integer.toString(lport));
+ prop.put("root", cvs_root);
+
+ CVSRepositoryLocation cvsrl = CVSRepositoryLocation.fromProperties(prop);
+
+ IConnectionMethod method = cvsrl.getMethod();
+ psc = method.createConnection(cvsrl, password);
+ } catch (Exception e) {
+ throw new CVSAuthenticationException(e.toString());
+ }
+ psc.open(monitor);
+ }
+} \ No newline at end of file

Back to the top