minor

src/explorviz/live_trace_processing/reader/TCPReader.java

@@ -18,9 +18,7 @@ import explorviz.live_trace_processing.filter.RecordArrayEventFactory;
 import explorviz.live_trace_processing.filter.reconstruction.TraceReconstructionFilter;
 
 public final class TCPReader {
-	static final int MESSAGE_BUFFER_SIZE = 131072;
-
-	static final int OUTPUT_MESSAGE_BUFFER_SIZE = 16384;
+	static final int OUTPUT_MESSAGE_BUFFER_SIZE = 8192;
 	private static final int RINGBUFFER_LENGTH = 16;
 
 	private final int listeningPort;

src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java

@@ -11,6 +11,7 @@ import java.util.concurrent.TimeUnit;
 
 import com.lmax.disruptor.RingBuffer;
 
+import explorviz.live_trace_processing.Constants;
 import explorviz.live_trace_processing.filter.RecordArrayEvent;
 import explorviz.live_trace_processing.filter.counting.CountingThroughputFilter;
 import explorviz.live_trace_processing.record.IRecord;
@@ -47,7 +48,8 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec
 
 	@Override
 	public void run() {
-		final ByteBuffer buffer = ByteBuffer.allocateDirect(TCPReader.MESSAGE_BUFFER_SIZE);
+		final ByteBuffer buffer = ByteBuffer
+				.allocateDirect(Constants.MONITORING_MESSAGE_BUFFER_SIZE);
 		try {
 			while ((socketChannel.read(buffer)) != -1) {
 				buffer.flip();