From 5b4daebbb2e8fd571456b44fe3757372286c46db Mon Sep 17 00:00:00 2001
From: Florian Fittkau <ffi@informatik.uni-kiel.de>
Date: Wed, 4 Dec 2013 09:51:25 +0100
Subject: [PATCH] minor
---
.../live_trace_processing/reader/TCPReaderOneClient.java | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
diff --git a/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java b/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java
index b3707a2..fcabc93 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());
--
GitLab