IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2024-11-24 17:50:27 -06:00
Code Issues Packages Projects Releases Wiki Activity

BaseOpDispenser changes

Browse Source
This commit is contained in:
Mark Wolters 2024-05-28 16:10:30 -04:00
parent a34a05c35d
commit 4e4f1fb0d1
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
nb-apis/adapters-api/src/main/java/io/nosqlbench/adapters/api/activityimpl/BaseOpDispenser.java
View File

@ -76,6 +76,7 @@ public abstract class BaseOpDispenser<T extends Op, S> extends NBBaseComponent i
*/
private final CycleFunction<Boolean> _verifier;
private final ThreadLocal<CycleFunction<Boolean>> tlVerifier;
private final ScopedValue<CycleFunction<Boolean>> cfVerifier;
protected BaseOpDispenser(final DriverAdapter<? extends T, ? extends S> adapter, final ParsedOp op) {
super(adapter);
@ -100,6 +101,8 @@ public abstract class BaseOpDispenser<T extends Op, S> extends NBBaseComponent i
verifiers = configureVerifiers(op);
this._verifier = CycleFunctions.of((a, b) -> a && b, verifiers, true);
this.tlVerifier = ThreadLocal.withInitial(_verifier::newInstance);
this.cfVerifier = ScopedValue.newInstance();
ScopedValue.where(cfVerifier, CycleFunctions.of((a, b) -> a && b, verifiers, true));
this.verifierTimer = create().timer(
"verifier",
3,