diff --git a/src/main/java/teetime/variant/methodcallWithPorts/stage/kieker/traceReduction/TraceReductionFilter.java b/src/main/java/teetime/variant/methodcallWithPorts/stage/kieker/traceReduction/TraceReductionFilter.java index 48570a3010c340c75cc0f50c6dc062497e0bbe21..f9484eb6c8e3abf4621d93047abac3e6dbdf2348 100644 --- a/src/main/java/teetime/variant/methodcallWithPorts/stage/kieker/traceReduction/TraceReductionFilter.java +++ b/src/main/java/teetime/variant/methodcallWithPorts/stage/kieker/traceReduction/TraceReductionFilter.java @@ -60,17 +60,14 @@ public class TraceReductionFilter extends ConsumerStage<TraceEventRecords, Trace } private void countSameTraces(final TraceEventRecords traceEventRecords, final long timestamp) { - TraceAggregationBuffer traceBuffer = this.trace2buffer.get(traceEventRecords); - if (traceBuffer == null) { - synchronized (this.trace2buffer) { - traceBuffer = this.trace2buffer.get(traceEventRecords); - if (traceBuffer == null) { // NOCS (DCL) - traceBuffer = new TraceAggregationBuffer(timestamp, traceEventRecords); - this.trace2buffer.put(traceEventRecords, traceBuffer); - } + synchronized (this.trace2buffer) { + TraceAggregationBuffer traceBuffer = this.trace2buffer.get(traceEventRecords); + if (traceBuffer == null) { + traceBuffer = new TraceAggregationBuffer(timestamp, traceEventRecords); + this.trace2buffer.put(traceEventRecords, traceBuffer); } + traceBuffer.count(); } - traceBuffer.count(); } @Override