From 10a74e73d4c0ce57ffa5440621cd794e5478bbed Mon Sep 17 00:00:00 2001 From: Simon Rettberg Date: Tue, 11 Apr 2017 15:13:51 +0200 Subject: [RemoteReboot] Apply code formatting --- .../openslx/taskmanager/tasks/RemoteReboot.java | 127 +++++++++++---------- 1 file changed, 68 insertions(+), 59 deletions(-) diff --git a/src/main/java/org/openslx/taskmanager/tasks/RemoteReboot.java b/src/main/java/org/openslx/taskmanager/tasks/RemoteReboot.java index f6ce4a7..041daaa 100644 --- a/src/main/java/org/openslx/taskmanager/tasks/RemoteReboot.java +++ b/src/main/java/org/openslx/taskmanager/tasks/RemoteReboot.java @@ -24,31 +24,31 @@ public class RemoteReboot extends AbstractTask { @Expose private Client[] clients; - + @Expose private boolean shutdown; - + @Expose private int minutes; - + @Expose private String locationId; - + @Expose private String locationName; - + @Expose private String sshkey; - + @Expose private int port; - + private Output status = new Output(); - + private static final String REBOOT_CMD = "/opt/openslx/scripts/idleaction-scheduled_action --detach reboot"; - + private static final String SHUTDOWN_CMD = "/opt/openslx/scripts/idleaction-scheduled_action --detach poweroff"; - + @Override protected boolean initTask() { @@ -68,9 +68,9 @@ public class RemoteReboot extends AbstractTask return false; status.clients = clients; - Date shutdownTime = new Date(System.currentTimeMillis()+minutes*60*1000); - SimpleDateFormat sdf = new SimpleDateFormat("HH:mm"); - status.time = sdf.format(shutdownTime); + Date shutdownTime = new Date( System.currentTimeMillis() + minutes * 60 * 1000 ); + SimpleDateFormat sdf = new SimpleDateFormat( "HH:mm" ); + status.time = sdf.format( shutdownTime ); status.locationId = locationId; status.locationName = locationName; return true; @@ -84,55 +84,56 @@ public class RemoteReboot extends AbstractTask final List rebootingClients = new ArrayList<>(); // try to connect to every client and start the reboot/shutdown process ExecutorService tp = Executors.newFixedThreadPool( clients.length > 4 ? 4 : clients.length ); - for (final Client client : clients) { + for ( final Client client : clients ) { if ( client == null || client.clientip == null || client.machineuuid == null ) { status.addError( "null Client or missing ip/uuid in list, ignoring." ); continue; } - status.clientStatus.put(client.machineuuid, ClientStatus.CONNECTING); - tp.submit(new Runnable() { - public void run() { - int ret = -1; + status.clientStatus.put( client.machineuuid, ClientStatus.CONNECTING ); + tp.submit( new Runnable() { + public void run() + { + int ret = -1; try { - Shell shell = new SSH(client.clientip, port, "root", sshkey); - if (shutdown) { - ret = new Shell.Empty(shell).exec(SHUTDOWN_CMD + " " + minutes); - status.clientStatus.put(client.machineuuid, minutes == 0 ? ClientStatus.SHUTDOWN : ClientStatus.SHUTDOWN_AT); + Shell shell = new SSH( client.clientip, port, "root", sshkey ); + if ( shutdown ) { + ret = new Shell.Empty( shell ).exec( SHUTDOWN_CMD + " " + minutes ); + status.clientStatus.put( client.machineuuid, minutes == 0 ? ClientStatus.SHUTDOWN : ClientStatus.SHUTDOWN_AT ); } else { - ret = new Shell.Empty(shell).exec(REBOOT_CMD + " " + minutes); - if (ret == 0) { - status.clientStatus.put(client.machineuuid, minutes == 0 ? ClientStatus.REBOOTING : ClientStatus.REBOOT_AT); - rebootingClients.add( client ); + ret = new Shell.Empty( shell ).exec( REBOOT_CMD + " " + minutes ); + if ( ret == 0 ) { + status.clientStatus.put( client.machineuuid, minutes == 0 ? ClientStatus.REBOOTING : ClientStatus.REBOOT_AT ); + rebootingClients.add( client ); } } - } catch (IOException e) { - if (e.toString().contains( "Auth fail" )) { - status.clientStatus.put(client.machineuuid, ClientStatus.AUTH_FAIL); + } catch ( IOException e ) { + if ( e.toString().contains( "Auth fail" ) ) { + status.clientStatus.put( client.machineuuid, ClientStatus.AUTH_FAIL ); ret = 0; } else { status.addError( client.clientip + ": " + e.toString() ); ret = -1; } } - if (ret != 0) { - if (ret != -1) { + if ( ret != 0 ) { + if ( ret != -1 ) { status.addError( client.clientip + ": Exit Code " + ret ); } - status.clientStatus.put(client.machineuuid, ClientStatus.ERROR); + status.clientStatus.put( client.machineuuid, ClientStatus.ERROR ); } } - }); + } ); } tp.shutdown(); - + try { tp.awaitTermination( clients.length * 5, TimeUnit.SECONDS ); } catch ( InterruptedException e ) { Thread.currentThread().interrupt(); return false; } - - if (minutes == 0 && rebootingClients.size() > 0) { + + if ( minutes == 0 && rebootingClients.size() > 0 ) { // Give about 3 minutes for reboot, should be plenty // Determine online state if either ssh or winrpc/smb is open final int[] ports; @@ -143,47 +144,47 @@ public class RemoteReboot extends AbstractTask } // Assume the boot loop takes at least 30 secs, don't even try before that try { - Thread.sleep(30000); - } catch (InterruptedException e) { + Thread.sleep( 30000 ); + } catch ( InterruptedException e ) { Thread.currentThread().interrupt(); return false; } long lastcheck = 0; long deadline = System.currentTimeMillis() + 120 * 1000; while ( rebootingClients.size() > 0 && System.currentTimeMillis() < deadline ) { - long delay = 10000 - (System.currentTimeMillis() - lastcheck); + long delay = 10000 - ( System.currentTimeMillis() - lastcheck ); if ( delay > 0 ) { try { - Thread.sleep(delay); - } catch (InterruptedException e) { + Thread.sleep( delay ); + } catch ( InterruptedException e ) { Thread.currentThread().interrupt(); return false; } } lastcheck = System.currentTimeMillis(); Iterator it = rebootingClients.iterator(); - while (it.hasNext()) { + while ( it.hasNext() ) { Client client = it.next(); - if (isOnline(client.clientip, ports)) { + if ( isOnline( client.clientip, ports ) ) { it.remove(); - status.clientStatus.put(client.machineuuid, ClientStatus.ONLINE); + status.clientStatus.put( client.machineuuid, ClientStatus.ONLINE ); } } } } - + // change status of clients that got stuck because of timeouts - for (Map.Entry entry : status.clientStatus.entrySet()) { + for ( Map.Entry entry : status.clientStatus.entrySet() ) { ClientStatus value = entry.getValue(); - if (value == ClientStatus.CONNECTING || (minutes == 0 && value == ClientStatus.REBOOTING)) { - entry.setValue(ClientStatus.ERROR); - } + if ( value == ClientStatus.CONNECTING || ( minutes == 0 && value == ClientStatus.REBOOTING ) ) { + entry.setValue( ClientStatus.ERROR ); + } } - + return true; } - - private boolean isOnline(String address, int... ports) + + private boolean isOnline( String address, int... ports ) { for ( int port : ports ) { try ( Socket s = new Socket() ) { @@ -194,8 +195,7 @@ public class RemoteReboot extends AbstractTask } return false; } - - + /** * Output - contains additional status data of this task */ @@ -208,6 +208,7 @@ public class RemoteReboot extends AbstractTask private String locationId; private String locationName; private String error; + private void addError( String e ) { if ( error == null ) { @@ -217,7 +218,7 @@ public class RemoteReboot extends AbstractTask } } } - + static class Client { @Expose @@ -225,9 +226,17 @@ public class RemoteReboot extends AbstractTask @Expose private String clientip; } - - static enum ClientStatus { - CONNECTING, REBOOTING, REBOOT_AT, SHUTDOWN, SHUTDOWN_AT, ONLINE, ERROR, AUTH_FAIL; + + static enum ClientStatus + { + CONNECTING, + REBOOTING, + REBOOT_AT, + SHUTDOWN, + SHUTDOWN_AT, + ONLINE, + ERROR, + AUTH_FAIL; } - + } -- cgit v1.2.3-55-g7522