diff --git a/src/explorviz/live_trace_processing/filter/counting/RecordCountingFilter.java b/src/explorviz/live_trace_processing/filter/counting/RecordCountingFilter.java index 48a5dd3758ff061f6097deceac9f1b5839ba2ceb..3bf89c518ca9705770f9dd911b702b0f7e1f74b6 100644 --- a/src/explorviz/live_trace_processing/filter/counting/RecordCountingFilter.java +++ b/src/explorviz/live_trace_processing/filter/counting/RecordCountingFilter.java @@ -3,13 +3,14 @@ package explorviz.live_trace_processing.filter.counting; import explorviz.live_trace_processing.filter.AbstractFilter; import explorviz.live_trace_processing.filter.IPipeReceiver; 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.trace.Trace; public class RecordCountingFilter extends AbstractFilter implements IRecordCounting { public RecordCountingFilter(final IPipeReceiver receiver) { - super(receiver, 16, 64, "Records/sec"); + super(receiver, 16, 64, "Methodcalls/sec"); counter.setEnabled(false); } @@ -17,10 +18,14 @@ public class RecordCountingFilter extends AbstractFilter implements IRecordCount public void processRecord(final IRecord record) { if (record instanceof Trace) { final Trace trace = (Trace) record; - if (trace.isValid()) { - counter.inputObjectsCount(trace.getTraceEvents().size()); + for (final AbstractEventRecord event : trace.getTraceEvents()) { + if (event instanceof AbstractBeforeEventRecord) { + final AbstractBeforeEventRecord abstractBeforeEventRecord = (AbstractBeforeEventRecord) event; + counter.inputObjectsCount(abstractBeforeEventRecord + .getRuntimeStatisticInformation().getCount()); + } } - } else if (record instanceof AbstractEventRecord) { + } else if (record instanceof AbstractBeforeEventRecord) { counter.inputObjectsCount(1); } else { deliver(record);