diff --git a/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java b/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java index 4c2cc58a625d7a1706a58199ebd8e3067f798660..f398afc554d28541bfaa3a261e828d5735f49120 100644 --- a/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java +++ b/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java @@ -195,7 +195,7 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec if (operation != null) { putInRingBuffer(new BeforeOperationEventRecord(timestamp, traceId, orderIndex, - operationId, operation)); + operation)); } else { final byte[] message = new byte[BeforeOperationEventRecord.BYTE_LENGTH_WITH_CLAZZ_ID]; buffer.position(buffer.position() @@ -217,7 +217,7 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec if ((operation != null) && (cause != null)) { putInRingBuffer(new AfterFailedOperationEventRecord(timestamp, traceId, orderIndex, - operationId, operation, cause)); + operation, cause)); } else { final byte[] message = new byte[AfterFailedOperationEventRecord.BYTE_LENGTH_WITH_CLAZZ_ID]; buffer.position(buffer.position() @@ -235,8 +235,7 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec final String operation = getStringFromRegistry(operationId); if (operation != null) { - putInRingBuffer(new AfterOperationEventRecord(timestamp, traceId, orderIndex, - operationId, operation)); + putInRingBuffer(new AfterOperationEventRecord(timestamp, traceId, orderIndex, operation)); } else { final byte[] message = new byte[AfterOperationEventRecord.BYTE_LENGTH_WITH_CLAZZ_ID]; buffer.position(buffer.position() - AfterOperationEventRecord.BYTE_LENGTH_WITH_CLAZZ_ID);