diff --git a/src/explorviz/live_trace_processing/reader/TCPReader.java b/src/explorviz/live_trace_processing/reader/TCPReader.java index 7199f9712727b41ea1070049f9febb0c932dd962..b8b2329efa9b8e217b9cd43868d47943b6069973 100644 --- a/src/explorviz/live_trace_processing/reader/TCPReader.java +++ b/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; diff --git a/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java b/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java index caa3119c2a23f02b6d723e8f8f01c35bff596365..ae022955bfb8ab4fd3f502d1884fe72c3e61580e 100644 --- a/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java +++ b/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();