Call CpsVmExecutorService.shutdown from CpsFlowExecution.suspendAll

Author: jglick

src/main/java/org/jenkinsci/plugins/workflow/cps/CpsFlowExecution.java

@@ -1584,6 +1584,15 @@ public void pause(final boolean v) throws IOException {
                             }
                         }
                         cpsExec.checkpoint(true);
+                        cpsExec.runInCpsVmThread(new FutureCallback<CpsThreadGroup>() {
+                            @Override public void onSuccess(CpsThreadGroup g) {
+                                LOGGER.fine(() -> "shutting down CPS VM threadin for " + cpsExec);
+                                g.shutdown();
+                            }
+                            @Override public void onFailure(Throwable t) {
+                                LOGGER.log(Level.WARNING, null, t);
+                            }
+                        });
                     }
                 } catch (Exception ex) {
                     LOGGER.log(Level.WARNING, "Error persisting Pipeline execution at shutdown: "+((CpsFlowExecution) execution).owner, ex);

src/main/java/org/jenkinsci/plugins/workflow/cps/CpsStepContext.java

@@ -436,12 +436,9 @@ public void onSuccess(CpsThreadGroup g) {
                     }
                     outcome = new Outcome(null, new AlreadyCompleted());
                 }
-
-                /**
-                 * Program state failed to load.
-                 */
                 @Override
                 public void onFailure(Throwable t) {
+                    LOGGER.log(Level.WARNING, "Failed to proceed after " + CpsStepContext.this, t);
                 }
             });
         } catch (IOException x) {

src/main/java/org/jenkinsci/plugins/workflow/cps/CpsThreadGroup.java

@@ -640,6 +640,10 @@ private void propagateErrorToWorkflow(Throwable t) {
         }
     }
 
+    void shutdown() {
+        runner.shutdown();
+    }
+
     private static final Logger LOGGER = Logger.getLogger(CpsThreadGroup.class.getName());
 
     private static final long serialVersionUID = 1L;