X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;ds=sidebyside;f=org.argeo.slc.support%2Fsrc%2Forg%2Fargeo%2Fslc%2Fjsch%2FAbstractJschTask.java;h=2dbcd84e74a3a9c01d7eca195049dbed7af7b511;hb=c0e2bd1da917c5c31810850c684631be9521d556;hp=ed37069ef3a14288230ff9abffc03109f49de3d2;hpb=b9505fef5ba8186433e903e9de3c73c17bdf6562;p=gpl%2Fargeo-slc.git

diff --git a/org.argeo.slc.support/src/org/argeo/slc/jsch/AbstractJschTask.java b/org.argeo.slc.support/src/org/argeo/slc/jsch/AbstractJschTask.java
index ed37069ef..2dbcd84e7 100644
--- a/org.argeo.slc.support/src/org/argeo/slc/jsch/AbstractJschTask.java
+++ b/org.argeo.slc.support/src/org/argeo/slc/jsch/AbstractJschTask.java
@@ -17,6 +17,7 @@ package org.argeo.slc.jsch;
 
 import java.io.IOException;
 import java.io.InputStream;
+import java.security.PrivilegedAction;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
@@ -24,7 +25,9 @@ import org.argeo.slc.SlcException;
 
 import com.jcraft.jsch.JSch;
 import com.jcraft.jsch.JSchException;
+import com.jcraft.jsch.Logger;
 import com.jcraft.jsch.Session;
+import com.jcraft.jsch.UserAuthGSSAPIWithMIC;
 
 public abstract class AbstractJschTask implements Runnable {
 	private final Log log = LogFactory.getLog(getClass());
@@ -36,38 +39,34 @@ public abstract class AbstractJschTask implements Runnable {
 			Session session = sshTarget.getSession();
 			if (session.isConnected()) {
 				if (log.isTraceEnabled())
-					log.debug("Using cached session to " + getSshTarget()
-							+ " via SSH");
+					log.debug("Using cached session to " + getSshTarget() + " via SSH");
 				return session;
 			}
 		}
 
 		try {
 			JSch jsch = new JSch();
-			if (sshTarget.getUsePrivateKey()
-					&& sshTarget.getLocalPrivateKey().exists())
-				jsch.addIdentity(sshTarget.getLocalPrivateKey()
-						.getAbsolutePath());
-			Session session = jsch.getSession(getSshTarget().getUser(),
-					getSshTarget().getHost(), getSshTarget().getPort());
+			if (sshTarget.getUsePrivateKey() && sshTarget.getLocalPrivateKey().exists())
+				jsch.addIdentity(sshTarget.getLocalPrivateKey().getAbsolutePath());
+			Session session = jsch.getSession(getSshTarget().getUser(), getSshTarget().getHost(),
+					getSshTarget().getPort());
 
 			session.setUserInfo(getSshTarget().getUserInfo());
+			session.setConfig("userauth.gssapi-with-mic", UserAuthGSSAPIWithMIC.class.getName());
 			session.setServerAliveInterval(1000);
 			session.connect();
 			if (log.isTraceEnabled())
 				log.trace("Connected to " + getSshTarget() + " via SSH");
 			if (sshTarget.getSession() != null) {
 				if (log.isTraceEnabled())
-					log.trace("The cached session to " + getSshTarget()
-							+ " was disconnected and was reset.");
+					log.trace("The cached session to " + getSshTarget() + " was disconnected and was reset.");
 				sshTarget.setSession(session);
 			}
 			return session;
 		} catch (JSchException e) {
 			if (sshTarget.getUserInfo() instanceof SimpleUserInfo)
 				((SimpleUserInfo) sshTarget.getUserInfo()).reset();
-			throw new SlcException("Could not open session to "
-					+ getSshTarget(), e);
+			throw new SlcException("Could not open session to " + getSshTarget(), e);
 		}
 	}
 
@@ -79,8 +78,7 @@ public abstract class AbstractJschTask implements Runnable {
 			if (sshTarget != null && sshTarget.getSession() == null) {
 				session.disconnect();
 				if (log.isTraceEnabled())
-					log.trace("Disconnected from " + getSshTarget()
-							+ " via SSH");
+					log.trace("Disconnected from " + getSshTarget() + " via SSH");
 			}
 		}
 	}
@@ -124,4 +122,34 @@ public abstract class AbstractJschTask implements Runnable {
 		this.sshTarget = sshTarget;
 	}
 
+	PrivilegedAction<Void> asPrivilegedAction() {
+		return new PrivilegedAction<Void>() {
+			public Void run() {
+				AbstractJschTask.this.run();
+				return null;
+			}
+		};
+	}
+
+	static {
+		JSch.setLogger(new JschLogger());
+	}
+
+	private static class JschLogger implements Logger {
+		private final Log log = LogFactory.getLog(JschLogger.class);
+
+		// TODO better support levels
+		@Override
+		public boolean isEnabled(int level) {
+			if (log.isTraceEnabled())
+				return true;
+			return false;
+		}
+
+		@Override
+		public void log(int level, String message) {
+			log.trace(message);
+		}
+
+	}
 }