Rename variable

Author: nielsbauman

server/src/main/java/org/elasticsearch/action/support/local/TransportLocalClusterStateAction.java

@@ -108,10 +108,10 @@ private void waitForClusterUnblock(
         );
         // We track whether we already notified the listener or started executing the action, to avoid invoking the listener twice.
         // Because of that second part, we can not use ActionListener#notifyOnce.
-        final var notifiedListener = new AtomicBoolean(false);
+        final var waitComplete = new AtomicBoolean(false);
         if (task instanceof CancellableTask cancellableTask) {
             cancellableTask.addListener(() -> {
-                if (notifiedListener.compareAndSet(false, true) == false) {
+                if (waitComplete.compareAndSet(false, true) == false) {
                     return;
                 }
                 listener.onFailure(new TaskCancelledException("Task was cancelled"));
@@ -121,7 +121,7 @@ private void waitForClusterUnblock(
         observer.waitForNextChange(new ClusterStateObserver.Listener() {
             @Override
             public void onNewClusterState(ClusterState state) {
-                if (notifiedListener.compareAndSet(false, true) == false) {
+                if (waitComplete.compareAndSet(false, true) == false) {
                     return;
                 }
                 logger.trace("retrying with cluster state version [{}]", state.version());
@@ -130,15 +130,15 @@ public void onNewClusterState(ClusterState state) {
 
             @Override
             public void onClusterServiceClose() {
-                if (notifiedListener.compareAndSet(false, true) == false) {
+                if (waitComplete.compareAndSet(false, true) == false) {
                     return;
                 }
                 listener.onFailure(new NodeClosedException(clusterService.localNode()));
             }
 
             @Override
             public void onTimeout(TimeValue timeout) {
-                if (notifiedListener.compareAndSet(false, true) == false) {
+                if (waitComplete.compareAndSet(false, true) == false) {
                     return;
                 }
                 logger.debug(

server/src/main/java/org/elasticsearch/action/support/master/TransportMasterNodeAction.java

@@ -307,10 +307,10 @@ private void retry(long currentStateVersion, final Throwable failure, final Pred
             }
             // We track whether we already notified the listener or started executing the action, to avoid invoking the listener twice.
             // Because of that second part, we can not use ActionListener#notifyOnce.
-            final var notifiedListener = new AtomicBoolean(false);
+            final var waitComplete = new AtomicBoolean(false);
             if (task instanceof CancellableTask cancellableTask) {
                 cancellableTask.addListener(() -> {
-                    if (notifiedListener.compareAndSet(false, true) == false) {
+                    if (waitComplete.compareAndSet(false, true) == false) {
                         return;
                     }
                     listener.onFailure(new TaskCancelledException("Task was cancelled"));
@@ -320,7 +320,7 @@ private void retry(long currentStateVersion, final Throwable failure, final Pred
             observer.waitForNextChange(new ClusterStateObserver.Listener() {
                 @Override
                 public void onNewClusterState(ClusterState state) {
-                    if (notifiedListener.compareAndSet(false, true) == false) {
+                    if (waitComplete.compareAndSet(false, true) == false) {
                         return;
                     }
                     logger.trace("retrying with cluster state version [{}]", state.version());
@@ -329,15 +329,15 @@ public void onNewClusterState(ClusterState state) {
 
                 @Override
                 public void onClusterServiceClose() {
-                    if (notifiedListener.compareAndSet(false, true) == false) {
+                    if (waitComplete.compareAndSet(false, true) == false) {
                         return;
                     }
                     listener.onFailure(new NodeClosedException(clusterService.localNode()));
                 }
 
                 @Override
                 public void onTimeout(TimeValue timeout) {
-                    if (notifiedListener.compareAndSet(false, true) == false) {
+                    if (waitComplete.compareAndSet(false, true) == false) {
                         return;
                     }
                     logger.debug(() -> format("timed out while retrying [%s] after failure (timeout [%s])", actionName, timeout), failure);