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

fix start-timers and stop-timers init logic

Browse Source
This commit is contained in:
Jonathan Shook 2022-05-31 21:01:59 -05:00
parent 24308575ee
commit 6e38f0bc99
1 changed files with 4 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
adapters-api/src/main/java/io/nosqlbench/engine/api/activityimpl/BaseOpDispenser.java
View File

@ -89,26 +89,12 @@ public abstract class BaseOpDispenser<T> implements OpDispenser<T> {
this.errorTimer = ActivityMetrics.timer(pop.getStaticConfigOr("alias", "UNKNOWN") + "-" + pop.getName() + "--error");
this.resultSizeHistogram = ActivityMetrics.histogram(pop.getStaticConfigOr("alias", "UNKNOWN") + "-" + pop.getName() + "--resultset-size");
}
timerStarts = pop.takeOptionalStaticValue("start-timers", String.class)
.map(s -> s.split(", *"))
.orElse(null);
if (timerStarts!=null) {
for (String timerStart : timerStarts) {
ThreadLocalNamedTimers.addTimer(pop,timerStart);
}
}
timerStops = pop.takeOptionalStaticValue("stop-timers", String.class)
.map(s -> s.split(", *"))
.orElse(null);
}
@Override
public void onStart(long cycleValue) {
if (timerStarts!=null) {
ThreadLocalNamedTimers.TL_INSTANCE.get().start(timerStops);
ThreadLocalNamedTimers.TL_INSTANCE.get().start(timerStarts);
}
}
@ -118,6 +104,9 @@ public abstract class BaseOpDispenser<T> implements OpDispenser<T> {
successTimer.update(nanoTime, TimeUnit.NANOSECONDS);
resultSizeHistogram.update(resultsize);
}
if (timerStops!=null) {
ThreadLocalNamedTimers.TL_INSTANCE.get().stop(timerStops);
}
// ThreadLocalNamedTimers.TL_INSTANCE.get().stop(stopTimers);
}