diff --git a/src/main/java/org/csanchez/jenkins/plugins/kubernetes/KubernetesLauncher.java b/src/main/java/org/csanchez/jenkins/plugins/kubernetes/KubernetesLauncher.java index 994ee25fad..c281fdab28 100644 --- a/src/main/java/org/csanchez/jenkins/plugins/kubernetes/KubernetesLauncher.java +++ b/src/main/java/org/csanchez/jenkins/plugins/kubernetes/KubernetesLauncher.java @@ -47,7 +47,6 @@ import java.util.List; import java.util.Map; import java.util.concurrent.TimeUnit; -import java.util.concurrent.atomic.AtomicBoolean; import java.util.logging.Level; import java.util.logging.Logger; import java.util.stream.Collectors; @@ -68,7 +67,7 @@ public class KubernetesLauncher extends JNLPLauncher { private static final Logger LOGGER = Logger.getLogger(KubernetesLauncher.class.getName()); - private final AtomicBoolean launched = new AtomicBoolean(false); + private volatile boolean launched = false; /** * Provisioning exception if any. @@ -87,7 +86,7 @@ public KubernetesLauncher() { @Override public boolean isLaunchSupported() { - return !launched.get(); + return !launched; } @Override @@ -104,7 +103,7 @@ public synchronized void launch(SlaveComputer computer, TaskListener listener) { if (node == null) { throw new IllegalStateException("Node has been removed, cannot launch " + computer.getName()); } - if (launched.get()) { + if (launched) { LOGGER.log(INFO, "Agent has already been launched, activating: {0}", node.getNodeName()); computer.setAcceptingTasks(true); return; @@ -288,7 +287,7 @@ public synchronized void launch(SlaveComputer computer, TaskListener listener) { } computer.setAcceptingTasks(true); - launched.set(true); + launched = true; try { // We need to persist the "launched" setting... node.save();