fix concurrency

piergm · Nov 14, 2024 · d87d2c0 · d87d2c0
1 parent 4e89c76
commit d87d2c0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/server/src/main/java/org/elasticsearch/action/search/AbstractSearchAsyncAction.java b/server/src/main/java/org/elasticsearch/action/search/AbstractSearchAsyncAction.java
@@ -251,7 +251,7 @@ public final void run() {
                 }
             }
             for (PendingExecutions pendingExecutions : pendingExecutionsPerNode.values()) {
-                if (pendingExecutions.released.compareAndSet(false, true) == false) {
+                if (pendingExecutions.released.compareAndSet(false, true)) {
                     pendingExecutions.semaphore.release(maxConcurrentRequestsPerNode);
                     pendingExecutions.flushQueue();
                 }
@@ -820,7 +820,7 @@ void submit(Consumer<Releasable> task) {
                 executeAndRelease(task);
             } else {
                 queue.add(task);
-                if (queuedItems.incrementAndGet() >= permits && released.compareAndSet(false, true) == false) {
+                if (queuedItems.incrementAndGet() >= permits && released.compareAndSet(false, true)) {
                     semaphore.release(permits);
                 }
                 flushQueue();