Skip to content
Snippets Groups Projects
Commit 423ad7d9 authored by Florian Fittkau's avatar Florian Fittkau
Browse files

fix

parent 23d062e6
No related branches found
No related tags found
No related merge requests found
......@@ -39,6 +39,7 @@ public class TracesSummarizationFilter extends AbstractFilter implements ITraceR
if (trace.isValid()) {
insertIntoBuffer(trace);
} else {
makeTraceElementsAccumulator(trace);
deliver(trace);
}
} else if (record instanceof TimedPeriodRecord) {
......@@ -56,14 +57,7 @@ public class TracesSummarizationFilter extends AbstractFilter implements ITraceR
private void insertIntoBuffer(final Trace trace) {
TracesSummarizationBuffer traceAggregationBuffer = trace2buffer.get(trace);
if (traceAggregationBuffer == null) {
for (int i = 0; i < trace.getTraceEvents().size(); i++) {
final AbstractEventRecord event = trace.getTraceEvents().get(i);
if (event instanceof AbstractBeforeEventRecord) {
final AbstractBeforeEventRecord abstractBeforeEventRecord = (AbstractBeforeEventRecord) event;
abstractBeforeEventRecord.getRuntimeStatisticInformation().makeAccumulator(
abstractBeforeEventRecord.getObjectId());
}
}
makeTraceElementsAccumulator(trace);
traceAggregationBuffer = new TracesSummarizationBuffer(
TimeProvider.getCurrentTimestamp());
......@@ -72,6 +66,17 @@ public class TracesSummarizationFilter extends AbstractFilter implements ITraceR
traceAggregationBuffer.insertTrace(trace);
}
public void makeTraceElementsAccumulator(final Trace trace) {
for (int i = 0; i < trace.getTraceEvents().size(); i++) {
final AbstractEventRecord event = trace.getTraceEvents().get(i);
if (event instanceof AbstractBeforeEventRecord) {
final AbstractBeforeEventRecord abstractBeforeEventRecord = (AbstractBeforeEventRecord) event;
abstractBeforeEventRecord.getRuntimeStatisticInformation().makeAccumulator(
abstractBeforeEventRecord.getObjectId());
}
}
}
private void processTimeoutQueue(final long timestamp) {
final long bufferTimeout = timestamp - maxCollectionDuration;
final List<Trace> toRemove = new ArrayList<Trace>();
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment