diff --git a/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java b/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java index b3707a201c1f5e53e045fbfff7d4388f5f12a963..fcabc9391eb53fad1991a2e7f5255320a3e32d6b 100644 --- a/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java +++ b/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java @@ -46,14 +46,11 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec @Override public void run() { - ByteBuffer buffer = ByteBuffer.allocateDirect(2 * 1024 * 1024); + final ByteBuffer buffer = ByteBuffer.allocateDirect(2 * 1024 * 1024); try { while ((socketChannel.read(buffer)) != -1) { buffer.flip(); messagesfromByteArray(buffer); - if (buffer.capacity() == buffer.position()) { - buffer = ByteBuffer.allocateDirect(2 * buffer.capacity()); - } } } catch (final IOException ex) { System.out.println("Error in read() " + ex.getMessage());