diff options
Diffstat (limited to 'src/main/java/org/openslx/taskmanager/tasks/RemoteExec.java')
| -rw-r--r-- | src/main/java/org/openslx/taskmanager/tasks/RemoteExec.java | 36 |
1 files changed, 33 insertions, 3 deletions
diff --git a/src/main/java/org/openslx/taskmanager/tasks/RemoteExec.java b/src/main/java/org/openslx/taskmanager/tasks/RemoteExec.java index de520a8..c533c27 100644 --- a/src/main/java/org/openslx/taskmanager/tasks/RemoteExec.java +++ b/src/main/java/org/openslx/taskmanager/tasks/RemoteExec.java @@ -50,6 +50,19 @@ public class RemoteExec extends AbstractTask private JSch sshClient; private Output status = new Output(); + + public RemoteExec() + { + } + + public RemoteExec(Client[] clients, String sshkey, int port, String command, int timeoutSeconds) + { + this.clients = clients; + this.sshkey = sshkey; + this.port = port; + this.command = command; + this.timeoutSeconds = timeoutSeconds; + } @Override protected boolean initTask() @@ -160,7 +173,12 @@ public class RemoteExec extends AbstractTask return true; } - + + public Output getStatusObject() + { + return this.status; + } + private void execCommand( ChannelExec channel, Client client, Result result ) throws JSchException, IOException { long st = System.currentTimeMillis(); @@ -279,9 +297,9 @@ public class RemoteExec extends AbstractTask static class Output { /** UUID -> Output */ - private Map<String, Result> result = new ConcurrentHashMap<>(); + Map<String, Result> result = new ConcurrentHashMap<>(); - private String error; + String error; private synchronized void addError( String e ) { @@ -305,6 +323,18 @@ public class RemoteExec extends AbstractTask private String username; /** How many ms of the given timeout are left */ private int timeoutLeft; + + public Client() + { + } + + public Client(String machineuuid, String clientip, int port, String username) + { + this.machineuuid = machineuuid; + this.clientip = clientip; + this.port = port; + this.username = username; + } } static enum State |