IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-04 11:50:34 -06:00
Code Issues Packages Projects Releases Wiki Activity

correct time base for await updates

Browse Source
This commit is contained in:
Jonathan Shook 2020-08-06 13:03:56 -05:00
parent 625be1db16
commit 2d39aad2b1
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
engine-core/src/main/java/io/nosqlbench/engine/core/script/ScenariosExecutor.java
View File

@ -92,14 +92,14 @@ public class ScenariosExecutor {
boolean isShutdown = false;
while (!isShutdown && System.currentTimeMillis() < timeoutAt) {
long updateAt = Math.min(timeoutAt, System.currentTimeMillis() + updateInterval);
long waitedAt = System.currentTimeMillis();
long updateAt = Math.min(timeoutAt, waitedAt + updateInterval);
while (!isShutdown && System.currentTimeMillis() < timeoutAt) {
while (!isShutdown && System.currentTimeMillis() < updateAt) {
try {
long timeRemaining = timeoutAt - System.currentTimeMillis();
isShutdown = executor.awaitTermination(timeRemaining, TimeUnit.MICROSECONDS);
long timeRemaining = updateAt - System.currentTimeMillis();
isShutdown = executor.awaitTermination(timeRemaining, TimeUnit.MILLISECONDS);
} catch (InterruptedException ignored) {
}
}