From 16aeb657ce42a0f9cd2d2289b9163ddf583e45c9 Mon Sep 17 00:00:00 2001
From: Florian Fittkau <ffi@informatik.uni-kiel.de>
Date: Wed, 11 Sep 2013 16:19:32 +0200
Subject: [PATCH] minor
---
.../filter/reconstruction/TraceReconstructionFilter.java | 2 +-
.../hpc_monitoring/reader/MessageDistributer.java | 8 ++++----
2 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/src/explorviz/hpc_monitoring/filter/reconstruction/TraceReconstructionFilter.java b/src/explorviz/hpc_monitoring/filter/reconstruction/TraceReconstructionFilter.java
index 5472dba..b4c8060 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 2175a44..3d6a6ad 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) {
--
GitLab