Change how min wait time is computed

kevinrr888 · Jan 4, 2024 · c98f70d · c98f70d
1 parent 1b885d8
commit c98f70d
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/core/src/main/java/org/apache/accumulo/core/fate/ZooStore.java b/core/src/main/java/org/apache/accumulo/core/fate/ZooStore.java
@@ -204,9 +204,10 @@ public long reserve() {
             if (deferred.isEmpty()) {
               this.wait(5000);
             } else {
-              Long minTime = Collections.min(deferred.values());
-              long waitTime = minTime - System.nanoTime();
-              waitTime = TimeUnit.MILLISECONDS.convert(waitTime, TimeUnit.NANOSECONDS);
+              long currTime = System.nanoTime();
+              long minWait =
+                  deferred.values().stream().mapToLong(l -> l - currTime).min().getAsLong();
+              long waitTime = TimeUnit.MILLISECONDS.convert(minWait, TimeUnit.NANOSECONDS);
               if (waitTime > 0) {
                 this.wait(Math.min(waitTime, 5000));
               }