summaryrefslogtreecommitdiffstats
path: root/vespaclient-container-plugin
diff options
context:
space:
mode:
authorJon Marius Venstad <venstad@gmail.com>2020-10-07 19:25:43 +0200
committerJon Marius Venstad <venstad@gmail.com>2020-10-07 19:25:43 +0200
commit10f3a803e1985b7bc1c09323d8da50f3eb2bbfd1 (patch)
tree7dcdb8e5d0736e1f97ae3ba011a7269a18e80f74 /vespaclient-container-plugin
parent958ff2da163fbe254b7baae7522c845ecfef38ad (diff)
Avoid wait(0)
Diffstat (limited to 'vespaclient-container-plugin')
-rw-r--r--vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/DocumentOperationExecutorImpl.java8
1 files changed, 4 insertions, 4 deletions
diff --git a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/DocumentOperationExecutorImpl.java b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/DocumentOperationExecutorImpl.java
index 1ebef129477..83640451601 100644
--- a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/DocumentOperationExecutorImpl.java
+++ b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/DocumentOperationExecutorImpl.java
@@ -159,9 +159,9 @@ public class DocumentOperationExecutorImpl implements DocumentOperationExecutor
Future<?> timeoutShutdown = timeouts.shutdown(Duration.ofSeconds(15),
context -> context.error(TIMEOUT, "Timed out due to shutdown"));
try {
- throttleShutdown.get(Math.max(0, shutdownMillis - clock.millis()), TimeUnit.MILLISECONDS);
- timeoutShutdown.get(Math.max(0, shutdownMillis - clock.millis()), TimeUnit.MILLISECONDS);
- visitSessionShutdownExecutor.awaitTermination(Math.max(0, shutdownMillis - clock.millis()), TimeUnit.MILLISECONDS);
+ throttleShutdown.get(Math.max(1, shutdownMillis - clock.millis()), TimeUnit.MILLISECONDS);
+ timeoutShutdown.get(Math.max(1, shutdownMillis - clock.millis()), TimeUnit.MILLISECONDS);
+ visitSessionShutdownExecutor.awaitTermination(Math.max(1, shutdownMillis - clock.millis()), TimeUnit.MILLISECONDS);
}
catch (InterruptedException | ExecutionException | TimeoutException e) {
throttleShutdown.cancel(true);
@@ -396,7 +396,7 @@ public class DocumentOperationExecutorImpl implements DocumentOperationExecutor
synchronized (this) {
do {
notify();
- wait(Math.max(0, waitUntilMillis - clock.millis()));
+ wait(Math.max(1, waitUntilMillis - clock.millis()));
}
while (clock.millis() < waitUntilMillis);
}