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

missed onEvent change

Browse Source
This commit is contained in:
Mark Wolters 2023-12-07 12:11:23 -04:00
parent 86f0a0298c
commit 79d6f65798
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
nb-api/src/main/java/io/nosqlbench/nb/api/components/NBBaseComponent.java
View File

@ -17,6 +17,7 @@
package io.nosqlbench.nb.api.components; package io.nosqlbench.nb.api.components;
import io.nosqlbench.nb.api.components.decorators.NBTokenWords; import io.nosqlbench.nb.api.components.decorators.NBTokenWords;
import io.nosqlbench.nb.api.components.events.ComponentOutOfScope;
import io.nosqlbench.nb.api.components.events.DownEvent; import io.nosqlbench.nb.api.components.events.DownEvent;
import io.nosqlbench.nb.api.components.events.NBEvent; import io.nosqlbench.nb.api.components.events.NBEvent;
import io.nosqlbench.nb.api.components.events.UpEvent; import io.nosqlbench.nb.api.components.events.UpEvent;
@ -171,6 +172,14 @@ public class NBBaseComponent extends NBBaseComponentMetrics implements NBCompone
child.onEvent(de); child.onEvent(de);
} }
} }
case ComponentOutOfScope coos -> {
for (NBMetric m : this.getComponentMetrics()) {
reportExecutionMetric(m);
}
if (bufferOrphanedMetrics) {
metricsBuffer.printMetricSummary(this);
}
}
default -> logger.warn("dropping event " + event); default -> logger.warn("dropping event " + event);
} }
} }