From 195f5c7d13c9c34f30ff649a024df91670868d84 Mon Sep 17 00:00:00 2001
From: Florian Fittkau <ffi@informatik.uni-kiel.de>
Date: Tue, 24 Mar 2015 10:15:11 +0100
Subject: [PATCH] WiP
---
.../reader/TCPReaderOneClient.java | 10 ++++++----
1 file changed, 6 insertions(+), 4 deletions(-)
diff --git a/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java b/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java
index 6119d57..0d98909 100644
--- a/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java
+++ b/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java
@@ -888,19 +888,21 @@ class TCPReaderOneClient extends Thread {
buffer.position(buffer.position() - length);
buffer.get(message);
waitingForStringMessages.add(message);
- System.out.println("waitingForStringMessages :" + waitingForStringMessages.size());
}
private final void checkWaitingMessages() {
- final List<byte[]> localWaitingList = new ArrayList<byte[]>();
- for (final byte[] waitingMessage : waitingForStringMessages) {
- localWaitingList.add(waitingMessage);
+ if (waitingForStringMessages.isEmpty()) {
+ return;
}
+
+ System.out.println("waitingForStringMessages: " + waitingForStringMessages.size());
+ final List<byte[]> localWaitingList = new ArrayList<byte[]>(waitingForStringMessages);
waitingForStringMessages.clear();
for (final byte[] waitingMessage : localWaitingList) {
final ByteBuffer buffer = ByteBuffer.wrap(waitingMessage);
final byte waitingMessageClazzId = buffer.get();
+ System.out.println("waitingForStringMessages clazzId: " + waitingMessageClazzId);
switch (waitingMessageClazzId) {
case HostApplicationMetaDataRecord.CLAZZ_ID:
readInHostApplicationMetaData(buffer);
--
GitLab