Merge pull request #417 from jglick/StepExecution.acceptAll

Using `StepExecution.acceptAll`

Author: jglick

pom.xml

@@ -83,6 +83,12 @@
                 <scope>import</scope>
                 <type>pom</type>
             </dependency>
+            <!-- TODO until in BOM: -->
+            <dependency>
+                <groupId>org.jenkins-ci.plugins.workflow</groupId>
+                <artifactId>workflow-step-api</artifactId>
+                <version>686.v603d058a_e148</version>
+            </dependency>
         </dependencies>
     </dependencyManagement>
     <dependencies>

src/main/java/org/jenkinsci/plugins/workflow/steps/durable_task/DurableTaskStep.java

@@ -762,12 +762,11 @@ private static class HandlerImpl extends Handler {
 
         private void check(Computer c) {
             String name = c.getName();
-            StepExecution.applyAll(Execution.class, exec -> {
+            StepExecution.acceptAll(Execution.class, exec -> {
                 if (exec.watching && exec.node.equals(name)) {
                     LOGGER.fine(() -> "Online/offline event on " + name + ", checking current status of " + exec.remote + " soon");
                     threadPool().schedule(exec::check, 15, TimeUnit.SECONDS);
                 }
-                return null;
             });
         }
 

src/main/java/org/jenkinsci/plugins/workflow/support/steps/ExecutorStepExecution.java

@@ -331,7 +331,7 @@ public void stop(@NonNull Throwable cause) throws Exception {
             }
             Set<StepContext> newAnomalous = new HashSet<>();
             Set<String> affectedNodes = new HashSet<>();
-            StepExecution.applyAll(ExecutorStepExecution.class, exec -> {
+            StepExecution.acceptAll(ExecutorStepExecution.class, exec -> {
                 StepContext ctx = exec.getContext();
                 if (!knownTasks.contains(ctx)) {
                     LOGGER.warning(() -> "do not know about " + ctx);
@@ -351,11 +351,10 @@ public void stop(@NonNull Throwable cause) throws Exception {
                 } else {
                     LOGGER.fine(() -> "know about " + ctx);
                 }
-                return null;
             }).get();
             // Also abort any shell steps running on the same node(s):
             if (!affectedNodes.isEmpty()) {
-                StepExecution.applyAll(DurableTaskStep.Execution.class, exec -> {
+                StepExecution.acceptAll(DurableTaskStep.Execution.class, exec -> {
                     if (affectedNodes.contains(exec.node)) {
                         StepContext ctx = exec.getContext();
                         try {
@@ -365,7 +364,6 @@ public void stop(@NonNull Throwable cause) throws Exception {
                         }
                         ctx.onFailure(new FlowInterruptedException(Result.ABORTED, false, new RemovedNodeCause()));
                     }
-                    return null;
                 });
             }
             for (StepContext ctx : newAnomalous) {