diff --git a/src/test/java/teetime/variant/methodcallWithPorts/examples/traceReading/ChwHomeTcpTraceReadingTest.java b/src/test/java/teetime/variant/methodcallWithPorts/examples/traceReading/ChwHomeTcpTraceReadingTest.java index 496d83ffa27a9fde674d39095ff62f2d4d040149..d21667dc78209871735699860cb45845cd35435f 100644 --- a/src/test/java/teetime/variant/methodcallWithPorts/examples/traceReading/ChwHomeTcpTraceReadingTest.java +++ b/src/test/java/teetime/variant/methodcallWithPorts/examples/traceReading/ChwHomeTcpTraceReadingTest.java @@ -81,7 +81,7 @@ public class ChwHomeTcpTraceReadingTest { assertEquals("#records", EXPECTED_NUM_RECORDS, analysis.getNumRecords()); // 08.07.2014 (incl.) - assertThat(recordQuintiles.get(0.5), is(both(greaterThan(3000L)).and(lessThan(3200L)))); + assertThat(recordQuintiles.get(0.5), is(both(greaterThan(3000L)).and(lessThan(3500L)))); } } diff --git a/src/test/java/teetime/variant/methodcallWithPorts/examples/traceReading/TcpTraceLoggingExtAnalysis.java b/src/test/java/teetime/variant/methodcallWithPorts/examples/traceReading/TcpTraceLoggingExtAnalysis.java index 08a004e696933484b2ff82499c73476b6bb209b5..2337ec8f6998ba96c0bfa8769817bfbeef6ef3df 100644 --- a/src/test/java/teetime/variant/methodcallWithPorts/examples/traceReading/TcpTraceLoggingExtAnalysis.java +++ b/src/test/java/teetime/variant/methodcallWithPorts/examples/traceReading/TcpTraceLoggingExtAnalysis.java @@ -19,9 +19,6 @@ import kieker.common.record.IMonitoringRecord; public class TcpTraceLoggingExtAnalysis extends Analysis { - private static final int MIO = 1000000; - private static final int TCP_RELAY_MAX_SIZE = 2 * MIO; - private Thread clockThread; private Thread tcpThread; @@ -53,7 +50,7 @@ public class TcpTraceLoggingExtAnalysis extends Analysis { SingleElementPipe.connect(this.recordCounter.getOutputPort(), this.recordThroughputStage.getInputPort()); SingleElementPipe.connect(this.recordThroughputStage.getOutputPort(), endStage.getInputPort()); - SpScPipe.connect(clockPipeline.getOutputPort(), this.recordThroughputStage.getTriggerInputPort(), TCP_RELAY_MAX_SIZE); + SpScPipe.connect(clockPipeline.getOutputPort(), this.recordThroughputStage.getTriggerInputPort(), 10); // create and configure pipeline Pipeline<Void, IMonitoringRecord> pipeline = new Pipeline<Void, IMonitoringRecord>(); diff --git a/src/test/java/teetime/variant/methodcallWithPorts/examples/traceReconstruction/TcpTraceReconstructionAnalysis.java b/src/test/java/teetime/variant/methodcallWithPorts/examples/traceReconstruction/TcpTraceReconstructionAnalysis.java index 994d3bc2d4e91d2222dbca8c428c7ae4559f78b1..3fccf84bd51456b60226a389d3aefa67c9276ad3 100644 --- a/src/test/java/teetime/variant/methodcallWithPorts/examples/traceReconstruction/TcpTraceReconstructionAnalysis.java +++ b/src/test/java/teetime/variant/methodcallWithPorts/examples/traceReconstruction/TcpTraceReconstructionAnalysis.java @@ -92,8 +92,8 @@ public class TcpTraceReconstructionAnalysis extends Analysis { SingleElementPipe.connect(traceReconstructionFilter.getOutputPort(), this.traceCounter.getInputPort()); SingleElementPipe.connect(this.traceCounter.getOutputPort(), endStage.getInputPort()); - SpScPipe.connect(clockStage.getOutputPort(), this.recordThroughputFilter.getTriggerInputPort(), 1); - SpScPipe.connect(clock2Stage.getOutputPort(), this.traceThroughputFilter.getTriggerInputPort(), 1); + SpScPipe.connect(clockStage.getOutputPort(), this.recordThroughputFilter.getTriggerInputPort(), 10); + SpScPipe.connect(clock2Stage.getOutputPort(), this.traceThroughputFilter.getTriggerInputPort(), 10); // create and configure pipeline Pipeline<Void, TraceEventRecords> pipeline = new Pipeline<Void, TraceEventRecords>();