diff --git a/engine-core/src/main/java/io/nosqlbench/engine/core/ActivityExecutor.java b/engine-core/src/main/java/io/nosqlbench/engine/core/ActivityExecutor.java index 166dd263c..30cd9aa2a 100644 --- a/engine-core/src/main/java/io/nosqlbench/engine/core/ActivityExecutor.java +++ b/engine-core/src/main/java/io/nosqlbench/engine/core/ActivityExecutor.java @@ -289,16 +289,17 @@ public class ActivityExecutor implements ActivityController, ParameterMap.Listen motors.add(motor); } - adjustToIntendedActivityState(); + applyIntendedStateToDivergentMotors(); awaitActivityAndMotorStateAlignment(); logger.trace(">post-adjust->" + getSlotStatus()); } - private void adjustToIntendedActivityState() { - logger.trace("ADJUSTING to INTENDED " + activity.getRunState()); - switch (activity.getRunState()) { + private void applyIntendedStateToDivergentMotors() { + RunState intended = activity.getRunState(); + logger.trace("ADJUSTING to INTENDED " + intended); + switch (intended) { case Uninitialized: break; case Running: