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

remove dead code

Browse Source
This commit is contained in:
Jonathan Shook 2023-12-20 17:16:28 -06:00
parent 0431c4be6e
commit cbc9e5484f
4 changed files with 0 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -126,7 +126,6 @@ public abstract class BaseOpDispenser<T extends Op, S> extends NBBaseComponent i
Binding variables = new Binding(); Binding variables = new Binding();
Map<String, ParsedTemplateString> initBlocks = op.getTemplateMap().takeAsNamedTemplates(VERIFIER_INIT); Map<String, ParsedTemplateString> initBlocks = op.getTemplateMap().takeAsNamedTemplates(VERIFIER_INIT);
List<CycleFunction<?>> verifierInitFunctions = new ArrayList<>();
try { try {
initBlocks.forEach((initName, stringTemplate) -> { initBlocks.forEach((initName, stringTemplate) -> {
GroovyCycleFunction<?> initFunction = GroovyCycleFunction<?> initFunction =

6
engine-core/src/main/java/io/nosqlbench/engine/api/activityapi/core/ComponentActivityInstrumentation.java
View File

@ -41,7 +41,6 @@ public class ComponentActivityInstrumentation implements ActivityInstrumentation
private NBMetricTimer cyclesServiceTimer; private NBMetricTimer cyclesServiceTimer;
private NBMetricTimer cyclesResponseTimer; private NBMetricTimer cyclesResponseTimer;
private NBMetricCounter pendingOpsCounter; private NBMetricCounter pendingOpsCounter;
private NBMetricCounter opTrackerBlockedCounter;
private NBMetricTimer bindTimer; private NBMetricTimer bindTimer;
private NBMetricTimer executeTimer; private NBMetricTimer executeTimer;
private NBMetricTimer resultTimer; private NBMetricTimer resultTimer;
@ -120,11 +119,6 @@ public class ComponentActivityInstrumentation implements ActivityInstrumentation
return pendingOpsCounter; return pendingOpsCounter;
} }
@Override
public Counter getOrCreateOpTrackerBlockedCounter() {
return opTrackerBlockedCounter;
}
@Override @Override
public Timer getOrCreateBindTimer() { public Timer getOrCreateBindTimer() {
return bindTimer; return bindTimer;

3
engine-core/src/main/java/io/nosqlbench/engine/api/activityimpl/motor/CoreMotor.java
View File

@ -75,8 +75,6 @@ public class CoreMotor<D> implements ActivityDefObserver, Motor<D>, Stoppable {
private int stride = 1; private int stride = 1;
private OpTracker<D> opTracker; private OpTracker<D> opTracker;
private Counter optrackerBlockCounter;
/** /**
* Create an ActivityMotor. * Create an ActivityMotor.
@ -194,7 +192,6 @@ public class CoreMotor<D> implements ActivityDefObserver, Motor<D>, Stoppable {
inputTimer = activity.getInstrumentation().getOrCreateInputTimer(); inputTimer = activity.getInstrumentation().getOrCreateInputTimer();
strideServiceTimer = activity.getInstrumentation().getOrCreateStridesServiceTimer(); strideServiceTimer = activity.getInstrumentation().getOrCreateStridesServiceTimer();
stridesResponseTimer = activity.getInstrumentation().getStridesResponseTimerOrNull(); stridesResponseTimer = activity.getInstrumentation().getStridesResponseTimerOrNull();
optrackerBlockCounter = activity.getInstrumentation().getOrCreateOpTrackerBlockedCounter();
strideRateLimiter = activity.getStrideLimiter(); strideRateLimiter = activity.getStrideLimiter();
cycleRateLimiter = activity.getCycleLimiter(); cycleRateLimiter = activity.getCycleLimiter();

5
engine-core/src/main/java/io/nosqlbench/engine/api/activityimpl/uniform/actions/StandardAction.java
View File

@ -48,9 +48,6 @@ import java.util.concurrent.TimeUnit;
*/ */
public class StandardAction<A extends StandardActivity<R, ?>, R extends Op> implements SyncAction, ActivityDefObserver { public class StandardAction<A extends StandardActivity<R, ?>, R extends Op> implements SyncAction, ActivityDefObserver {
private final static Logger logger = LogManager.getLogger("ACTION"); private final static Logger logger = LogManager.getLogger("ACTION");
private final A activity;
private final int slot;
private final Timer executeTimer; private final Timer executeTimer;
private final Histogram triesHistogram; private final Histogram triesHistogram;
private final Timer resultSuccessTimer; private final Timer resultSuccessTimer;
@ -62,9 +59,7 @@ public class StandardAction<A extends StandardActivity<R, ?>, R extends Op> impl
private final Timer verifierTimer; private final Timer verifierTimer;
public StandardAction(A activity, int slot) { public StandardAction(A activity, int slot) {
this.activity = activity;
this.opsequence = activity.getOpSequence(); this.opsequence = activity.getOpSequence();
this.slot = slot;
this.maxTries = activity.getMaxTries(); this.maxTries = activity.getMaxTries();
bindTimer = activity.getInstrumentation().getOrCreateBindTimer(); bindTimer = activity.getInstrumentation().getOrCreateBindTimer();
executeTimer = activity.getInstrumentation().getOrCreateExecuteTimer(); executeTimer = activity.getInstrumentation().getOrCreateExecuteTimer();