IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'main' into mwolters/sqlite

Browse Source
This commit is contained in:
Mark Wolters
2024-05-30 10:40:41 -04:00
parent c566aa493f 24a449c951
commit 6f768fc42d
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
nbr/src/main/java/io/nosqlbench/scenarios/simframe/SimFrameUtils.java
View File

@@ -27,6 +27,7 @@ import java.util.Optional;
import java.util.concurrent.locks.LockSupport; import java.util.concurrent.locks.LockSupport;
public class SimFrameUtils { public class SimFrameUtils {
public static final String SIM_CYCLES = "sim_cycles";
public static void awaitActivity(Activity flywheel) { public static void awaitActivity(Activity flywheel) {
// await flywheel actually spinning, or timeout with error // await flywheel actually spinning, or timeout with error
@@ -54,6 +55,8 @@ public class SimFrameUtils {
// Start the flywheel at an "idle" speed, even if the user hasn't set it // Start the flywheel at an "idle" speed, even if the user hasn't set it
flywheel.onEvent(new ParamChange<>(new CycleRateSpec(100.0d, 1.1d, SimRateSpec.Verb.restart))); flywheel.onEvent(new ParamChange<>(new CycleRateSpec(100.0d, 1.1d, SimRateSpec.Verb.restart)));
flywheel.getActivityDef().setEndCycle(Long.MAX_VALUE); flywheel.getActivityDef().setEndCycle(Long.MAX_VALUE);
flywheel.getActivityDef().getParams().set(SIM_CYCLES, Long.MAX_VALUE);
return flywheel; return flywheel;
} }
} }