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

invalid traces also do objectId

parent 6e62e31c
No related branches found
No related tags found
No related merge requests found
......@@ -32,6 +32,7 @@ class TraceReconstructionBuffer {
openEvents++;
final AbstractBeforeEventRecord beforeEvent = (AbstractBeforeEventRecord) event;
beforeEvent.setRuntimeStatisticInformation(new RuntimeStatisticInformation(1, -1, -1)); // TODO
// if
// invalid,
// trace
......
......@@ -25,16 +25,6 @@ class TracesSummarizationBuffer {
public void insertTrace(final Trace trace) {
if (accumulator == null) {
accumulator = 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());
}
}
} else {
final List<AbstractEventRecord> aggregatedRecords = accumulator.getTraceEvents();
final List<AbstractEventRecord> records = trace.getTraceEvents();
......@@ -45,6 +35,7 @@ class TracesSummarizationBuffer {
final AbstractBeforeEventRecord abstractBeforeEventRecord = (AbstractBeforeEventRecord) event;
final AbstractBeforeEventRecord abstractBeforeEventRecord2 = (AbstractBeforeEventRecord) records
.get(i);
abstractBeforeEventRecord.getRuntimeStatisticInformation().merge(
abstractBeforeEventRecord2.getRuntimeStatisticInformation(),
abstractBeforeEventRecord2.getObjectId());
......
......@@ -10,6 +10,8 @@ import explorviz.live_trace_processing.filter.AbstractFilter;
import explorviz.live_trace_processing.filter.IPipeReceiver;
import explorviz.live_trace_processing.reader.TimeProvider;
import explorviz.live_trace_processing.record.IRecord;
import explorviz.live_trace_processing.record.event.AbstractBeforeEventRecord;
import explorviz.live_trace_processing.record.event.AbstractEventRecord;
import explorviz.live_trace_processing.record.misc.TerminateRecord;
import explorviz.live_trace_processing.record.misc.TimedPeriodRecord;
import explorviz.live_trace_processing.record.trace.Trace;
......@@ -35,6 +37,16 @@ public class TracesSummarizationFilter extends AbstractFilter implements ITraceR
public void processRecord(final IRecord record) {
if (record instanceof Trace) {
final Trace trace = (Trace) record;
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());
}
}
if (trace.isValid()) {
insertIntoBuffer(trace);
} else {
......
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