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

update seq length and cycle warning to be more correct, less chatty

Browse Source
This commit is contained in:
Jonathan Shook 2020-07-17 17:30:38 -05:00
parent 60360b459f
commit b5879e2aff
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
engine-api/src/main/java/io/nosqlbench/engine/api/activityimpl/SimpleActivity.java
View File

@ -287,7 +287,8 @@ public class SimpleActivity implements Activity {
long cycleCount = getActivityDef().getCycleCount(); long cycleCount = getActivityDef().getCycleCount();
long stride = getActivityDef().getParams().getOptionalLong("stride").orElseThrow(); long stride = getActivityDef().getParams().getOptionalLong("stride").orElseThrow();
if ((cycleCount % stride) != 0) {
if (stride>0 && (cycleCount % stride) != 0) {
logger.warn("The stride does not evenly divide cycles. Only full strides will be executed," + logger.warn("The stride does not evenly divide cycles. Only full strides will be executed," +
"leaving some cycles unused."); "leaving some cycles unused.");
} }
@ -331,6 +332,9 @@ public class SimpleActivity implements Activity {
} }
} }
if (activityDef.getCycleCount()>0 && seq.getOps().size()==0) {
throw new BasicError("You have configured a zero-length sequence and non-zero cycles. Tt is not possible to continue with this activity.");
}
} }
protected <O> OpSequence<O> createOpSequenceFromCommands(Function<CommandTemplate, O> opinit) { protected <O> OpSequence<O> createOpSequenceFromCommands(Function<CommandTemplate, O> opinit) {