diff --git a/src/explorviz/live_trace_processing/filter/reconstruction/TraceReconstructionFilter.java b/src/explorviz/live_trace_processing/filter/reconstruction/TraceReconstructionFilter.java index 084b9d17d6dbfd996f06def8dcc845312c16ca94..5d340213108503e5fafcdcb1a87aac3f6a46b22e 100644 --- a/src/explorviz/live_trace_processing/filter/reconstruction/TraceReconstructionFilter.java +++ b/src/explorviz/live_trace_processing/filter/reconstruction/TraceReconstructionFilter.java @@ -73,6 +73,8 @@ public final class TraceReconstructionFilter extends AbstractFilter implements R private void checkForTimeouts(final long timestamp) { final long traceTimeout = timestamp - maxTraceTimeout; + System.out.println("Trace Recon Filter Size: " + traceIdAndHost2trace.size()); + final Iterator<Entry<AbstractEventRecord, TraceReconstructionBuffer>> iterator = traceIdAndHost2trace .entrySet().iterator(); diff --git a/src/explorviz/live_trace_processing/filter/reduction/TracesSummarizationFilter.java b/src/explorviz/live_trace_processing/filter/reduction/TracesSummarizationFilter.java index b3f0126663986d4ecb7f8cb2e4925e26a9edf45a..96577e7fbcd6eaa9c7b99281f2555d9adbd51549 100644 --- a/src/explorviz/live_trace_processing/filter/reduction/TracesSummarizationFilter.java +++ b/src/explorviz/live_trace_processing/filter/reduction/TracesSummarizationFilter.java @@ -111,6 +111,8 @@ public class TracesSummarizationFilter extends AbstractFilter { final Iterator<Entry<Trace, TracesSummarizationBuffer>> iter = trace2buffer.entrySet() .iterator(); + System.out.println("Trace Sum Filter Size: " + trace2buffer.size()); + while (iter.hasNext()) { final Entry<Trace, TracesSummarizationBuffer> traceBufferEntry = iter.next(); diff --git a/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java b/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java index 848c07ae5b9838ce57726b91a33b33530dbc345e..6119d5757d61d05129e4c56b52f9895cf36d8faa 100644 --- a/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java +++ b/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java @@ -888,6 +888,7 @@ class TCPReaderOneClient extends Thread { buffer.position(buffer.position() - length); buffer.get(message); waitingForStringMessages.add(message); + System.out.println("waitingForStringMessages :" + waitingForStringMessages.size()); } private final void checkWaitingMessages() {