added scripts

scripts/MooBench-cmd/META-INF/kieker.aop.xml

+<!DOCTYPE aspectj PUBLIC "-//AspectJ//DTD//EN" "http://www.aspectj.org/dtd/aspectj_1_5_0.dtd">
+<aspectj>
+    <weaver options="">
+        <include within="mooBench.monitoredApplication.*"/>
+        <include within="kieker.monitoring.probe..*"/>
+    </weaver>
+    <aspects>
+        <aspect name="kieker.monitoring.probe.aspectj.flow.operationExecution.FullInstrumentation" />
+    </aspects>
+</aspectj>

scripts/MooBench-cmd/META-INF/kieker.legacy.aop.xml

+<!DOCTYPE aspectj PUBLIC "-//AspectJ//DTD//EN" "http://www.aspectj.org/dtd/aspectj_1_5_0.dtd">
+<aspectj>
+    <weaver options="">
+        <include within="mooBench.monitoredApplication.*"/>
+    </weaver>
+    <aspects>
+        <aspect name="kieker.monitoring.probe.aspectj.operationExecution.OperationExecutionAspectFull"/>
+    </aspects>
+</aspectj>

scripts/MooBench-cmd/META-INF/kieker.logging.properties

+handlers = java.util.logging.FileHandler
+java.util.logging.FileHandler.level = ALL
+java.util.logging.FileHandler.formatter = java.util.logging.SimpleFormatter
+java.util.logging.FileHandler.append = true
+java.util.logging.FileHandler.pattern = kieker.log

scripts/MooBench-cmd/META-INF/kieker.monitoring.properties

+kieker.monitoring.enabled=true
+kieker.monitoring.name=KIEKER-BENCHMARK
+
+kieker.monitoring.adaptiveMonitoring.enabled=false
+kieker.monitoring.periodicSensorsExecutorPoolSize=0
+
+kieker.monitoring.writer.AsyncDummyWriter.QueueSize=100000
+kieker.monitoring.writer.AsyncDummyWriter.QueueFullBehavior=1
+
+kieker.monitoring.writer.filesystem.SyncFsWriter.bufferSize=16777216
+kieker.monitoring.writer.filesystem.SyncFsWriter.flush=false
+
+kieker.monitoring.writer.filesystem.AsyncFsWriter.QueueSize=100000
+kieker.monitoring.writer.filesystem.AsyncFsWriter.QueueFullBehavior=1
+kieker.monitoring.writer.filesystem.AsyncFsWriter.bufferSize=16777216
+kieker.monitoring.writer.filesystem.AsyncFsWriter.flush=false
+
+kieker.monitoring.writer.filesystem.AsyncBinaryFsWriter.QueueSize=100000
+kieker.monitoring.writer.filesystem.AsyncBinaryFsWriter.QueueFullBehavior=1
+kieker.monitoring.writer.filesystem.AsyncBinaryFsWriter.bufferSize=16777216
+
+kieker.monitoring.writer.filesystem.AsyncBinaryZipWriter.QueueSize=100000
+kieker.monitoring.writer.filesystem.AsyncBinaryZipWriter.QueueFullBehavior=1
+kieker.monitoring.writer.filesystem.AsyncBinaryZipWriter.bufferSize=16777216
+
+kieker.monitoring.writer.tcp.TCPWriter.QueueFullBehavior=1
+kieker.monitoring.writer.tcp.TCPWriter.QueueSize=100000

scripts/MooBench-cmd/startMooBench.cmd

+
+set cp=.;MooBench.jar;META-INF/kieker.monitoring.properties;META-INF/kieker.logging.properties
+set jvmParams=-javaagent:lib/kieker-1.9_aspectj.jar -Dorg.aspectj.weaver.loadtime.configuration=META-INF/kieker.aop.xml -Dorg.aspectj.weaver.showWeaveInfo=true -Daj.weaving.verbose=true -Dkieker.monitoring.writer=kieker.monitoring.writer.tcp.TCPWriter
+set params=-d 10 -h 1 -m 0 -t 1000000 -o tmp/test.txt -q
+set runs=%1
+
+for %%i in (1,1,%runs%) do (
+	java -cp %cp% %jvmParams% mooBench.benchmark.Benchmark %params%
+)
\ No newline at end of file

scripts/teetime-cmd/startTeetime.cmd

+
+set cp=.;teetime.jar;lib/kieker-1.9_aspectj.jar
+set jvmParams=
+set params=
+
+java -cp %cp% %jvmParams% teetime.variant.methodcallWithPorts.examples.traceReconstructionWithThreads.ChwWorkTcpTraceReconstructionAnalysisWithThreadsTest %params%
\ No newline at end of file

src/test/java/teetime/variant/methodcallWithPorts/examples/traceReconstructionWithThreads/ChwWorkTcpTraceReconstructionAnalysisWithThreadsTest.java

@@ -48,9 +48,23 @@ public class ChwWorkTcpTraceReconstructionAnalysisWithThreadsTest {
 	}
 
 	@Test
-	public void performAnalysis() {
+	public void performAnalysisWith1Thread() {
+		this.performAnalysis(1);
+	}
+
+	@Test
+	public void performAnalysisWith2Threads() {
+		this.performAnalysis(2);
+	}
+
+	@Test
+	public void performAnalysisWith4Threads() {
+		this.performAnalysis(4);
+	}
+
+	void performAnalysis(final int numWorkerThreads) {
 		final TcpTraceReconstructionAnalysisWithThreads analysis = new TcpTraceReconstructionAnalysisWithThreads();
-		analysis.setNumWorkerThreads(2);
+		analysis.setNumWorkerThreads(numWorkerThreads);
 		analysis.init();
 
 		this.stopWatch.start();
@@ -79,4 +93,31 @@ public class ChwWorkTcpTraceReconstructionAnalysisWithThreadsTest {
 		assertEquals(21000001, analysis.getNumRecords());
 	}
 
+	public static void main(final String[] args) {
+		ChwWorkTcpTraceReconstructionAnalysisWithThreadsTest analysis = new ChwWorkTcpTraceReconstructionAnalysisWithThreadsTest();
+		analysis.before();
+		try {
+			analysis.performAnalysisWith1Thread();
+		} catch (Exception e) {
+			System.err.println(e);
+		}
+		analysis.after();
+
+		analysis.before();
+		try {
+			analysis.performAnalysisWith2Threads();
+		} catch (Exception e) {
+			System.err.println(e);
+		}
+		analysis.after();
+
+		analysis.before();
+		try {
+			analysis.performAnalysisWith4Threads();
+		} catch (Exception e) {
+			System.err.println(e);
+		}
+		analysis.after();
+	}
+
 }

src/test/java/teetime/variant/methodcallWithPorts/examples/traceReconstructionWithThreads/TcpTraceReconstructionAnalysisWithThreads.java

@@ -136,7 +136,7 @@ public class TcpTraceReconstructionAnalysisWithThreads extends Analysis {
 		Pipeline<IMonitoringRecord, IMonitoringRecord> pipeline = new Pipeline<IMonitoringRecord, IMonitoringRecord>();
 		pipeline.setFirstStage(relay);
 		// pipeline.addIntermediateStage(this.recordCounter);
-		pipeline.addIntermediateStage(sysout);
+		// pipeline.addIntermediateStage(sysout);
 		// pipeline.addIntermediateStage(instanceOfFilter);
 		// pipeline.addIntermediateStage(this.recordThroughputFilter);
 		// pipeline.addIntermediateStage(traceReconstructionFilter);