WiP

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();
 

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();
 

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() {