diff --git a/src/explorviz/hpc_monitoring/filter/reconstruction/TraceReconstructionFilter.java b/src/explorviz/hpc_monitoring/filter/reconstruction/TraceReconstructionFilter.java index 5472dba27c572d78e1b71da02ed3066a23fff44c..b4c8060d5c1d421848e34f767eed2d922d779d82 100644 --- a/src/explorviz/hpc_monitoring/filter/reconstruction/TraceReconstructionFilter.java +++ b/src/explorviz/hpc_monitoring/filter/reconstruction/TraceReconstructionFilter.java @@ -67,7 +67,7 @@ public final class TraceReconstructionFilter implements private void sendOutValidTrace(final Trace trace) { counter.inputObjects(trace); - // putInRingBuffer(trace); + putInRingBuffer(trace); } private void sendOutInvalidTrace(final Trace trace) { diff --git a/src/explorviz/hpc_monitoring/reader/MessageDistributer.java b/src/explorviz/hpc_monitoring/reader/MessageDistributer.java index 2175a44fd9bf9c26bfccf097522e94f0767ff179..3d6a6ad80d6aa633469ef292d383c611f4befc6a 100644 --- a/src/explorviz/hpc_monitoring/reader/MessageDistributer.java +++ b/src/explorviz/hpc_monitoring/reader/MessageDistributer.java @@ -275,10 +275,10 @@ public class MessageDistributer implements EventHandler<ByteArrayEvent> { private void putInRingBuffer(final IRecord record) { counter.inputObjects(record); - // final long hiseq = ringBuffer.next(); - // final RecordEvent valueEvent = ringBuffer.get(hiseq); - // valueEvent.setValue(record); - // ringBuffer.publish(hiseq); + final long hiseq = ringBuffer.next(); + final RecordEvent valueEvent = ringBuffer.get(hiseq); + valueEvent.setValue(record); + ringBuffer.publish(hiseq); } public void addToRegistry(final int key, final String value) {