From ee65f9e2a1aa7c36b5767a08b66e19c25a229f4c Mon Sep 17 00:00:00 2001
From: Florian Fittkau <ffi@informatik.uni-kiel.de>
Date: Tue, 12 Nov 2013 22:25:52 +0100
Subject: [PATCH] minor
---
src/explorviz/live_trace_processing/reader/TCPReader.java | 4 +---
.../live_trace_processing/reader/TCPReaderOneClient.java | 4 +++-
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/src/explorviz/live_trace_processing/reader/TCPReader.java b/src/explorviz/live_trace_processing/reader/TCPReader.java
index 7199f97..b8b2329 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 caa3119..ae02295 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();
--
GitLab