]>
git.argeo.org Git - gpl/argeo-slc.git/blob - org.argeo.slc.support/src/org/argeo/slc/jsch/AbstractJschTask.java
1 package org
.argeo
.slc
.jsch
;
3 import java
.io
.IOException
;
4 import java
.io
.InputStream
;
5 import java
.security
.PrivilegedAction
;
7 import org
.apache
.commons
.logging
.Log
;
8 import org
.apache
.commons
.logging
.LogFactory
;
9 import org
.argeo
.slc
.SlcException
;
11 import com
.jcraft
.jsch
.JSch
;
12 import com
.jcraft
.jsch
.JSchException
;
13 import com
.jcraft
.jsch
.Logger
;
14 import com
.jcraft
.jsch
.Session
;
15 import com
.jcraft
.jsch
.UserAuthGSSAPIWithMIC
;
17 public abstract class AbstractJschTask
implements Runnable
{
18 private final Log log
= LogFactory
.getLog(getClass());
20 private SshTarget sshTarget
;
22 protected Session
openSession() {
23 if (sshTarget
.getSession() != null) {
24 Session session
= sshTarget
.getSession();
25 if (session
.isConnected()) {
26 if (log
.isTraceEnabled())
27 log
.debug("Using cached session to " + getSshTarget() + " via SSH");
33 JSch jsch
= new JSch();
34 if (sshTarget
.getUsePrivateKey() && sshTarget
.getLocalPrivateKey().exists())
35 jsch
.addIdentity(sshTarget
.getLocalPrivateKey().getAbsolutePath());
36 Session session
= jsch
.getSession(getSshTarget().getUser(), getSshTarget().getHost(),
37 getSshTarget().getPort());
39 session
.setUserInfo(getSshTarget().getUserInfo());
40 session
.setConfig("userauth.gssapi-with-mic", UserAuthGSSAPIWithMIC
.class.getName());
41 session
.setServerAliveInterval(1000);
43 if (log
.isTraceEnabled())
44 log
.trace("Connected to " + getSshTarget() + " via SSH");
45 if (sshTarget
.getSession() != null) {
46 if (log
.isTraceEnabled())
47 log
.trace("The cached session to " + getSshTarget() + " was disconnected and was reset.");
48 sshTarget
.setSession(session
);
51 } catch (JSchException e
) {
52 if (sshTarget
.getUserInfo() instanceof SimpleUserInfo
)
53 ((SimpleUserInfo
) sshTarget
.getUserInfo()).reset();
54 throw new SlcException("Could not open session to " + getSshTarget(), e
);
59 Session session
= openSession();
63 if (sshTarget
!= null && sshTarget
.getSession() == null) {
65 if (log
.isTraceEnabled())
66 log
.trace("Disconnected from " + getSshTarget() + " via SSH");
71 abstract void run(Session session
);
73 protected int checkAck(InputStream in
) throws IOException
{
75 // b may be 0 for success,
82 return b
;// throw new SlcException("SSH ack returned -1");
83 else if (b
== 1 || b
== 2) {
84 StringBuffer sb
= new StringBuffer();
90 if (b
== 1) { // error
91 throw new SlcException("SSH ack error: " + sb
.toString());
93 if (b
== 2) { // fatal error
94 throw new SlcException("SSH fatal error: " + sb
.toString());
100 public SshTarget
getSshTarget() {
101 if (sshTarget
== null)
102 throw new SlcException("No SSH target defined.");
106 public void setSshTarget(SshTarget sshTarget
) {
107 this.sshTarget
= sshTarget
;
110 PrivilegedAction
<Void
> asPrivilegedAction() {
111 return new PrivilegedAction
<Void
>() {
113 AbstractJschTask
.this.run();
120 JSch
.setLogger(new JschLogger());
123 private static class JschLogger
implements Logger
{
124 private final Log log
= LogFactory
.getLog(JschLogger
.class);
126 // TODO better support levels
128 public boolean isEnabled(int level
) {
129 if (log
.isTraceEnabled())
135 public void log(int level
, String message
) {