Commit 195f5c7d authored by Florian Fittkau's avatar Florian Fittkau

WiP

parent 09353d99
......@@ -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);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment