fix WinRM thread leak

src/main/java/hudson/plugins/ec2/win/EC2WindowsLauncher.java

@@ -61,54 +61,69 @@
 
             logger.println("Creating tmp directory if it does not exist");
             WindowsProcess mkdirProcess = connection.execute("if not exist " + tmpDir + " mkdir " + tmpDir);
-            int exitCode = mkdirProcess.waitFor();
-            if (exitCode != 0) {
-                logger.println("Creating tmpdir failed=" + exitCode);
-                return;
+            try {
+                int exitCode = mkdirProcess.waitFor();
+                if (exitCode != 0) {
+                    logger.println("Creating tmpdir failed=" + exitCode);
+                    return;
+                }
+            } catch (Exception e) {
+                mkdirProcess.destroy();
+                throw e;
             }
 
             if (initScript != null && !initScript.trim().isEmpty() && !connection.exists(tmpDir + ".jenkins-init")) {
                 logger.println("Executing init script");
                 try (OutputStream init = connection.putFile(tmpDir + "init.bat")) {
                     init.write(initScript.getBytes(StandardCharsets.UTF_8));
                 }
 
                 WindowsProcess initProcess = connection.execute("cmd /c " + tmpDir + "init.bat");
-                IOUtils.copy(initProcess.getStdout(), logger);
+                try {
+                    IOUtils.copy(initProcess.getStdout(), logger);
 
-                int exitStatus = initProcess.waitFor();
-                if (exitStatus != 0) {
-                    logger.println("init script failed: exit code=" + exitStatus);
-                    return;
+                    int exitStatus = initProcess.waitFor();
+                    if (exitStatus != 0) {
+                        logger.println("init script failed: exit code=" + exitStatus);
+                        return;
+                    }
+                } catch (Exception e) {
+                    initProcess.destroy();
+                    throw e;
                 }
 
                 try (OutputStream initGuard = connection.putFile(tmpDir + ".jenkins-init")) {
                     initGuard.write("init ran".getBytes(StandardCharsets.UTF_8));
                 }
                 logger.println("init script ran successfully");
             }
 
             try (OutputStream agentJar = connection.putFile(tmpDir + AGENT_JAR)) {
                 agentJar.write(Jenkins.get().getJnlpJars(AGENT_JAR).readFully());
             }
 
             logger.println("remoting.jar sent remotely. Bootstrapping it");
 
             final String javaPath = node.javaPath;
             final String jvmopts = node.jvmopts;
             final String remoteFS = WindowsUtil.quoteArgument(node.getRemoteFS());
             final String workDir = Util.fixEmptyAndTrim(remoteFS) != null ? remoteFS : tmpDir;
             final String launchString = javaPath + " " + (jvmopts != null ? jvmopts : "") + " -jar " + tmpDir
                     + AGENT_JAR + " -workDir " + workDir;
             logger.println("Launching via WinRM:" + launchString);
             final WindowsProcess process = connection.execute(launchString, 86400);
-            computer.setChannel(process.getStdout(), process.getStdin(), logger, new Listener() {
-                @Override
-                public void onClosed(Channel channel, IOException cause) {
-                    process.destroy();
-                    connection.close();
-                }
-            });
+            try {
+                computer.setChannel(process.getStdout(), process.getStdin(), logger, new Listener() {
+                    @Override
+                    public void onClosed(Channel channel, IOException cause) {
+                        process.destroy();
+                        connection.close();
+                    }
+                });
+            } catch (Exception e) {
+                process.destroy();
+                throw e;
+            }
         } catch (EOFException eof) {
             // When we launch java with connection.execute(launchString... it keeps running, but if java is not
             // installed

src/main/java/hudson/plugins/ec2/win/winrm/WindowsProcess.java

@@ -86,8 +86,19 @@
             return;
         }
 
-        client.signal();
-        client.deleteShell();
+        // Instance may already be terminated, causing WinRM operations to fail
+        try {
+            client.signal();
+        } catch (Exception e) {
+            LOGGER.log(Level.FINE, () -> "Failed to signal WinRM shell: " + e.getMessage());
+        }
+
+        try {
+            client.deleteShell();
+        } catch (Exception e) {
+            LOGGER.log(Level.FINE, () -> "Failed to delete WinRM shell: " + e.getMessage());
+        }
+
         terminated = true;
         Closeables.closeQuietly(toCallersStdout);
         Closeables.closeQuietly(toCallersStdin);