diff --git a/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java b/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java index 4705d165f1c7bb3aba95bfd2c7cf13b110d1524a..3fe9a599091d7fa9e7cacd3fefe9b0df061a55b1 100644 --- a/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java +++ b/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java @@ -400,12 +400,15 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec private final void readInReceivedRemoteCallEvent(final ByteBuffer buffer) { final long callerTraceId = buffer.getLong(); final int callerOrderIndex = buffer.getInt(); - System.out.println("worker: received remote - callerTraceId: " + callerTraceId); final long timestamp = buffer.getLong(); final long traceId = buffer.getLong(); final int orderIndex = buffer.getInt(); + System.out.println("worker: received remote " + + new ReceivedRemoteCallRecord(timestamp, callerTraceId, callerOrderIndex, traceId, + orderIndex, hostApplicationMetadata).toString()); + putInRingBuffer(new ReceivedRemoteCallRecord(timestamp, callerTraceId, callerOrderIndex, traceId, orderIndex, hostApplicationMetadata)); } @@ -459,9 +462,12 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec final int orderIndex = buffer.getInt(); final int destinationId = buffer.getInt(); - System.out.println("worker: sent remote - traceId: " + traceId); - try { + System.out.println("worker: sent remote: " + + new SentRemoteCallRecord(timestamp, stringRegistry + .getStringFromId(destinationId), traceId, orderIndex, + hostApplicationMetadata).toString()); + putInRingBuffer(new SentRemoteCallRecord(timestamp, stringRegistry.getStringFromId(destinationId), traceId, orderIndex, hostApplicationMetadata));