From e728407e5d33ac80e3c017ac3934cbb7fc739fd4 Mon Sep 17 00:00:00 2001
From: Florian Fittkau <ffi@informatik.uni-kiel.de>
Date: Tue, 10 Dec 2013 15:32:10 +0100
Subject: [PATCH] compressed sizes
---
.../reader/TCPReaderOneClient.java | 17 ++++++++++-------
1 file changed, 10 insertions(+), 7 deletions(-)
diff --git a/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java b/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java
index 0a3933e..a1e64d1 100644
--- a/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java
+++ b/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java
@@ -90,7 +90,7 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec
break;
}
case BeforeOperationEventRecord.CLAZZ_ID: {
- if (buffer.remaining() >= (BeforeOperationEventRecord.BYTE_LENGTH_WITH_CLAZZ_ID - 1)) {
+ if (buffer.remaining() >= BeforeOperationEventRecord.COMPRESSED_BYTE_LENGTH) {
readInBeforeOperationEvent(buffer);
} else {
buffer.position(buffer.position() - 1);
@@ -100,7 +100,7 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec
break;
}
case AfterFailedOperationEventRecord.CLAZZ_ID: {
- if (buffer.remaining() >= (AfterFailedOperationEventRecord.BYTE_LENGTH_WITH_CLAZZ_ID - 1)) {
+ if (buffer.remaining() >= AfterFailedOperationEventRecord.COMPRESSED_BYTE_LENGTH) {
readInAfterFailedOperationEvent(buffer);
} else {
buffer.position(buffer.position() - 1);
@@ -110,7 +110,7 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec
break;
}
case AfterOperationEventRecord.CLAZZ_ID: {
- if (buffer.remaining() >= (AfterOperationEventRecord.BYTE_LENGTH_WITH_CLAZZ_ID - 1)) {
+ if (buffer.remaining() >= AfterOperationEventRecord.COMPRESSED_BYTE_LENGTH) {
readInAfterOperationEvent(buffer);
} else {
buffer.position(buffer.position() - 1);
@@ -147,7 +147,7 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec
break;
}
case SystemMonitoringRecord.CLAZZ_ID: {
- if (buffer.remaining() >= (SystemMonitoringRecord.BYTE_LENGTH_WITH_CLAZZ_ID - 1)) {
+ if (buffer.remaining() >= SystemMonitoringRecord.BYTE_LENGTH) {
readInSystemMonitoringRecord(buffer);
} else {
buffer.position(buffer.position() - 1);
@@ -232,7 +232,8 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec
putInRingBuffer(new BeforeOperationEventRecord(timestamp, traceId, orderIndex,
operation, hostApplicationMetadata, new RuntimeStatisticInformation(timestamp)));
} catch (final IdNotAvailableException e) {
- putInWaitingMessages(buffer, 1 + 8 + 8 + 4 + 4);
+ putInWaitingMessages(buffer,
+ BeforeOperationEventRecord.COMPRESSED_BYTE_LENGTH_WITH_CLAZZ_ID);
}
}
@@ -251,7 +252,8 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec
operation, cause, hostApplicationMetadata, new RuntimeStatisticInformation(
timestamp)));
} catch (final IdNotAvailableException e) {
- putInWaitingMessages(buffer, 1 + 8 + 8 + 4 + 4 + 4);
+ putInWaitingMessages(buffer,
+ AfterFailedOperationEventRecord.COMPRESSED_BYTE_LENGTH_WITH_CLAZZ_ID);
}
}
@@ -267,7 +269,8 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec
putInRingBuffer(new AfterOperationEventRecord(timestamp, traceId, orderIndex,
operation, hostApplicationMetadata, new RuntimeStatisticInformation(timestamp)));
} catch (final IdNotAvailableException e) {
- putInWaitingMessages(buffer, 1 + 8 + 8 + 4 + 4);
+ putInWaitingMessages(buffer,
+ AfterOperationEventRecord.COMPRESSED_BYTE_LENGTH_WITH_CLAZZ_ID);
}
}
--
GitLab