diff options
Diffstat (limited to 'vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/DocumentQueue.java')
| -rw-r--r-- | vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/DocumentQueue.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/DocumentQueue.java b/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/DocumentQueue.java index 6462ee1b2cd..cefa8d6e94a 100644 --- a/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/DocumentQueue.java +++ b/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/DocumentQueue.java @@ -52,9 +52,9 @@ class DocumentQueue { Document poll(long timeout, TimeUnit unit) throws InterruptedException { synchronized (queue) { - long startTime = System.currentTimeMillis(); long remainingToWait = unit.toMillis(timeout); while (queue.isEmpty()) { + long startTime = System.currentTimeMillis(); queue.wait(remainingToWait); remainingToWait -= (System.currentTimeMillis() - startTime); if (remainingToWait <= 0) { |