summaryrefslogtreecommitdiffstats
path: root/src/main/java/org/openslx/taskmanager
diff options
context:
space:
mode:
authorSimon Rettberg2022-01-31 15:10:00 +0100
committerSimon Rettberg2022-01-31 15:10:00 +0100
commitf2310d81bb5bd9994cdcf0ed35060e3b9815fc7e (patch)
tree704727f556de6078a97773072e70f67fb91a45b6 /src/main/java/org/openslx/taskmanager
parent[WakeOnLan] Add more status output (diff)
downloadtmlite-bwlp-f2310d81bb5bd9994cdcf0ed35060e3b9815fc7e.tar.gz
tmlite-bwlp-f2310d81bb5bd9994cdcf0ed35060e3b9815fc7e.tar.xz
tmlite-bwlp-f2310d81bb5bd9994cdcf0ed35060e3b9815fc7e.zip
[RemoteExec] Fix instantiating via parametrized constructor
Diffstat (limited to 'src/main/java/org/openslx/taskmanager')
-rw-r--r--src/main/java/org/openslx/taskmanager/tasks/RemoteExec.java1
-rw-r--r--src/main/java/org/openslx/taskmanager/tasks/WakeOnLan.java16
2 files changed, 10 insertions, 7 deletions
diff --git a/src/main/java/org/openslx/taskmanager/tasks/RemoteExec.java b/src/main/java/org/openslx/taskmanager/tasks/RemoteExec.java
index c533c27..cc7631d 100644
--- a/src/main/java/org/openslx/taskmanager/tasks/RemoteExec.java
+++ b/src/main/java/org/openslx/taskmanager/tasks/RemoteExec.java
@@ -62,6 +62,7 @@ public class RemoteExec extends AbstractTask
this.port = port;
this.command = command;
this.timeoutSeconds = timeoutSeconds;
+ initTask();
}
@Override
diff --git a/src/main/java/org/openslx/taskmanager/tasks/WakeOnLan.java b/src/main/java/org/openslx/taskmanager/tasks/WakeOnLan.java
index 2391d4d..17780b5 100644
--- a/src/main/java/org/openslx/taskmanager/tasks/WakeOnLan.java
+++ b/src/main/java/org/openslx/taskmanager/tasks/WakeOnLan.java
@@ -93,14 +93,17 @@ public class WakeOnLan extends AbstractTask
}
list.add( client.mac );
}
+ if ( byMethod.isEmpty() )
+ break;
+ status.addMsg( "Starting job distribution..." );
// Execute
List<Future<?>> waitList = new ArrayList<>();
for ( Entry<String, ArrayList<String>> it : byMethod.entrySet() ) {
- String[] parts = it.getKey().split( "//" );
- String method = parts[0];
- List<String> macs = it.getValue();
- String macString = Strings.join( macs.iterator(), ' ' );
- String ip = parts[1];
+ final String[] parts = it.getKey().split( "//" );
+ final String method = parts[0];
+ final List<String> macs = it.getValue();
+ final String macString = Strings.join( macs.iterator(), ' ' );
+ final String ip = parts[1];
final int jobId = ++jobIdCounter;
if ( method.equalsIgnoreCase( "DIRECT" ) ) {
// Directly from server
@@ -164,8 +167,7 @@ public class WakeOnLan extends AbstractTask
e.printStackTrace();
}
}
- // If we had any jobs to do, loop again, otherwise we're done
- } while ( !byMethod.isEmpty() );
+ } while ( true );
status.addMsg( "Mainloop done" );
if ( this.clients.isEmpty() )
return true;