diff --git a/conf/logging.properties b/conf/logging.properties
index 7a943c39409bbb9dd2237c02bca2d3450dc2a822..3e86eac8825fa96ce44b9eeae6883d9f55da6a5e 100644
--- a/conf/logging.properties
+++ b/conf/logging.properties
@@ -1,7 +1,7 @@
.handlers = java.util.logging.ConsoleHandler
-.level= ALL
+.level = ALL
-java.util.logging.ConsoleHandler.level = INFO
+java.util.logging.ConsoleHandler.level = WARNING
#java.util.logging.ConsoleHandler.formatter = java.util.logging.SimpleFormatter
java.util.logging.SimpleFormatter.format=[%1$tF %1$tr] %4$s: %5$s (%2$s)%n
diff --git a/src/main/java/kieker/analysis/stage/CacheFilter.java b/src/main/java/kieker/analysis/stage/CacheFilter.java
index 9d9d94b14533b0ca7475b1e61c495c9f6974227b..9aaac112c74a5dd94fd7e0ddbfd57ffd7c74ff3b 100644
--- a/src/main/java/kieker/analysis/stage/CacheFilter.java
+++ b/src/main/java/kieker/analysis/stage/CacheFilter.java
@@ -17,6 +17,9 @@ package kieker.analysis.stage;
import java.util.ArrayList;
import java.util.List;
+import java.util.concurrent.TimeUnit;
+
+import teetime.util.StopWatch;
import kieker.analysis.IProjectContext;
import kieker.analysis.plugin.annotation.InputPort;
@@ -45,9 +48,13 @@ public class CacheFilter extends AbstractFilterPlugin {
@Override
public void terminate(final boolean error) {
+ StopWatch stopWatch = new StopWatch();
+ stopWatch.start();
for (final Object data : this.cache) {
super.deliver(EmptyPassOnFilter.OUTPUT_PORT_NAME, data);
}
+ stopWatch.end();
+ System.out.println("dur: " + TimeUnit.NANOSECONDS.toMillis(stopWatch.getDurationInNs()) + " ms");
super.terminate(error);
}
diff --git a/src/main/java/teetime/variant/methodcallWithPorts/framework/core/ConsumerStage.java b/src/main/java/teetime/variant/methodcallWithPorts/framework/core/ConsumerStage.java
index 940fefdb91751e13a3cb694f61b9f256a050874e..331e42060cde3277bc733960e48b6438a021f5ee 100644
--- a/src/main/java/teetime/variant/methodcallWithPorts/framework/core/ConsumerStage.java
+++ b/src/main/java/teetime/variant/methodcallWithPorts/framework/core/ConsumerStage.java
@@ -20,7 +20,10 @@ public abstract class ConsumerStage<I, O> extends AbstractStage<I, O> {
@Override
public void executeWithPorts() {
- this.logger.debug("Executing stage...");
+ // if (this.logger.isDebugEnabled()) {
+ // this.logger.debug("Executing stage...");
+ // }
+
I element = this.getInputPort().receive();
this.setReschedulable(this.getInputPort().getPipe().size() > 0);
diff --git a/src/main/java/teetime/variant/methodcallWithPorts/stage/Cache.java b/src/main/java/teetime/variant/methodcallWithPorts/stage/Cache.java
index 460f08f74e723f09ec6ce16b28d21e7ae0bb8383..44213e2910d02f75f3e37ae6ed03105b9751e8c3 100644
--- a/src/main/java/teetime/variant/methodcallWithPorts/stage/Cache.java
+++ b/src/main/java/teetime/variant/methodcallWithPorts/stage/Cache.java
@@ -2,7 +2,9 @@ package teetime.variant.methodcallWithPorts.stage;
import java.util.LinkedList;
import java.util.List;
+import java.util.concurrent.TimeUnit;
+import teetime.util.StopWatch;
import teetime.variant.methodcallWithPorts.framework.core.ConsumerStage;
public class Cache<T> extends ConsumerStage<T, T> {
@@ -17,9 +19,13 @@ public class Cache<T> extends ConsumerStage<T, T> {
@Override
public void onIsPipelineHead() {
this.logger.debug("Emitting cached elements...");
+ StopWatch stopWatch = new StopWatch();
+ stopWatch.start();
for (T cachedElement : this.cachedObjects) {
this.send(cachedElement);
}
+ stopWatch.end();
+ System.out.println("dur: " + TimeUnit.NANOSECONDS.toMillis(stopWatch.getDurationInNs()) + " ms");
super.onIsPipelineHead();
}
diff --git a/src/main/java/teetime/variant/methodcallWithPorts/stage/CountingFilter.java b/src/main/java/teetime/variant/methodcallWithPorts/stage/CountingFilter.java
index 08ad2ac8622990d1640ff3870d4152cd784d240e..39a1647715bd878663574b19c7e63c65f1e7eca3 100644
--- a/src/main/java/teetime/variant/methodcallWithPorts/stage/CountingFilter.java
+++ b/src/main/java/teetime/variant/methodcallWithPorts/stage/CountingFilter.java
@@ -9,6 +9,7 @@ public class CountingFilter<T> extends ConsumerStage<T, T> {
@Override
protected void execute5(final T element) {
this.numElementsPassed++;
+ // this.logger.info("count: " + this.numElementsPassed);
this.send(element);
}
diff --git a/src/main/java/teetime/variant/methodcallWithPorts/stage/ThroughputFilter.java b/src/main/java/teetime/variant/methodcallWithPorts/stage/ThroughputFilter.java
index 87abfc8d810709912f60f1b5839556350d8c2a84..c15f8610445423c201b5607bba6bdf5b4f0526fd 100644
--- a/src/main/java/teetime/variant/methodcallWithPorts/stage/ThroughputFilter.java
+++ b/src/main/java/teetime/variant/methodcallWithPorts/stage/ThroughputFilter.java
@@ -35,12 +35,13 @@ public class ThroughputFilter<T> extends ConsumerStage<T, T> {
private void computeThroughput() {
long diffInNs = System.nanoTime() - this.timestamp;
- // long diffInMs = TimeUnit.NANOSECONDS.toMillis(diffInNs);
- // long throughputPerMs = this.numPassedElements / diffInMs;
- long diffInSec = TimeUnit.NANOSECONDS.toSeconds(diffInNs);
- long throughputPerSec = this.numPassedElements / diffInSec;
- this.throughputs.add(throughputPerSec);
- this.logger.info("Throughput: " + throughputPerSec + " elements/s");
+ long diffInMs = TimeUnit.NANOSECONDS.toMillis(diffInNs);
+ long throughputPerMs = this.numPassedElements / diffInMs;
+ this.throughputs.add(throughputPerMs);
+ // this.logger.info("Throughput: " + throughputPerMs + " elements/ms");
+
+ // long diffInSec = TimeUnit.NANOSECONDS.toSeconds(diffInNs);
+ // long throughputPerSec = this.numPassedElements / diffInSec;
}
private void resetTimestamp() {
diff --git a/src/main/java/teetime/variant/methodcallWithPorts/stage/basic/merger/Merger.java b/src/main/java/teetime/variant/methodcallWithPorts/stage/basic/merger/Merger.java
index daed0fa5db4cb07b0902aa5ae6da185e8ee0b77a..70ec23873c60b18af3e79440e8f9d917afdd3f3f 100644
--- a/src/main/java/teetime/variant/methodcallWithPorts/stage/basic/merger/Merger.java
+++ b/src/main/java/teetime/variant/methodcallWithPorts/stage/basic/merger/Merger.java
@@ -52,7 +52,9 @@ public class Merger<T> extends ConsumerStage<T, T> {
@Override
public void executeWithPorts() {
- this.logger.debug("Executing stage...");
+ // if (this.logger.isDebugEnabled()) {
+ // this.logger.debug("Executing stage...");
+ // }
this.execute5(null);
diff --git a/src/test/java/teetime/variant/methodcallWithPorts/examples/traceReconstruction/TraceReconstructionAnalysis.java b/src/test/java/teetime/variant/methodcallWithPorts/examples/traceReconstruction/TraceReconstructionAnalysis.java
index 76a10668248890349eb4c3b899b9bfd201eb49b6..071a7aa07daafd9256a09dc11f6eebcde9475008 100644
--- a/src/test/java/teetime/variant/methodcallWithPorts/examples/traceReconstruction/TraceReconstructionAnalysis.java
+++ b/src/test/java/teetime/variant/methodcallWithPorts/examples/traceReconstruction/TraceReconstructionAnalysis.java
@@ -56,7 +56,7 @@ public class TraceReconstructionAnalysis extends Analysis {
private StageWithPort<Void, Long> buildClockPipeline() {
Clock clock = new Clock();
- clock.setIntervalDelayInMs(50);
+ clock.setIntervalDelayInMs(100);
return clock;
}
@@ -64,19 +64,12 @@ public class TraceReconstructionAnalysis extends Analysis {
private Pipeline<File, Void> buildPipeline(final StageWithPort<Void, Long> clockStage) {
this.classNameRegistryRepository = new ClassNameRegistryRepository();
- // final IsIMonitoringRecordInRange isIMonitoringRecordInRange = new IsIMonitoringRecordInRange(0, 1000);
- // final IsOperationExecutionRecordTraceIdPredicate isOperationExecutionRecordTraceIdPredicate = new IsOperationExecutionRecordTraceIdPredicate(
- // false, null);
// create stages
final Dir2RecordsFilter dir2RecordsFilter = new Dir2RecordsFilter(this.classNameRegistryRepository);
this.recordCounter = new CountingFilter<IMonitoringRecord>();
final Cache<IMonitoringRecord> cache = new Cache<IMonitoringRecord>();
final StringBufferFilter<IMonitoringRecord> stringBufferFilter = new StringBufferFilter<IMonitoringRecord>();
- // final PredicateFilter<IMonitoringRecord> timestampFilter = new PredicateFilter<IMonitoringRecord>(
- // isIMonitoringRecordInRange);
- // final PredicateFilter<OperationExecutionRecord> traceIdFilter = new PredicateFilter<OperationExecutionRecord>(
- // isOperationExecutionRecordTraceIdPredicate);
final InstanceOfFilter<IMonitoringRecord, IFlowRecord> instanceOfFilter = new InstanceOfFilter<IMonitoringRecord, IFlowRecord>(
IFlowRecord.class);
this.throughputFilter = new ThroughputFilter<IFlowRecord>();