From 43046300ba03e95dc99df5a882eab91980fba34a Mon Sep 17 00:00:00 2001
From: Florian Fittkau <ffi@informatik.uni-kiel.de>
Date: Tue, 18 Mar 2014 20:36:14 +0100
Subject: [PATCH] fixed minor bug
---
.../filter/counting/RecordCountingFilter.java | 16 +++++++++++++++-
1 file changed, 15 insertions(+), 1 deletion(-)
diff --git a/src/explorviz/live_trace_processing/filter/counting/RecordCountingFilter.java b/src/explorviz/live_trace_processing/filter/counting/RecordCountingFilter.java
index f7a60a1..64fda94 100644
--- a/src/explorviz/live_trace_processing/filter/counting/RecordCountingFilter.java
+++ b/src/explorviz/live_trace_processing/filter/counting/RecordCountingFilter.java
@@ -5,6 +5,8 @@ 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.misc.TerminateRecord;
+import explorviz.live_trace_processing.record.misc.TimedPeriodRecord;
import explorviz.live_trace_processing.record.trace.Trace;
public class RecordCountingFilter extends AbstractFilter implements IRecordCounting {
@@ -25,10 +27,22 @@ public class RecordCountingFilter extends AbstractFilter implements IRecordCount
.getRuntimeStatisticInformation().getCount());
}
}
+ deliver(record);
} else if (record instanceof AbstractBeforeEventRecord) {
counter.inputObjectsCount(1);
+ deliver(record);
+ } else if (record instanceof TimedPeriodRecord) {
+ periodicFlush(record);
+ // deliver(record);
+ } else if (record instanceof TerminateRecord) {
+ terminate();
+ deliver(record);
+ } else {
+ deliver(record);
}
+ }
+
+ private void terminate() {
- deliver(record);
}
}
--
GitLab