Skip to content
Snippets Groups Projects
Commit 8e41a2ff authored by Florian Fittkau's avatar Florian Fittkau
Browse files

debug for remote

parent 50c050b9
No related branches found
No related tags found
No related merge requests found
...@@ -400,12 +400,15 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec ...@@ -400,12 +400,15 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec
private final void readInReceivedRemoteCallEvent(final ByteBuffer buffer) { private final void readInReceivedRemoteCallEvent(final ByteBuffer buffer) {
final long callerTraceId = buffer.getLong(); final long callerTraceId = buffer.getLong();
final int callerOrderIndex = buffer.getInt(); final int callerOrderIndex = buffer.getInt();
System.out.println("worker: received remote - callerTraceId: " + callerTraceId);
final long timestamp = buffer.getLong(); final long timestamp = buffer.getLong();
final long traceId = buffer.getLong(); final long traceId = buffer.getLong();
final int orderIndex = buffer.getInt(); 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, putInRingBuffer(new ReceivedRemoteCallRecord(timestamp, callerTraceId, callerOrderIndex,
traceId, orderIndex, hostApplicationMetadata)); traceId, orderIndex, hostApplicationMetadata));
} }
...@@ -459,9 +462,12 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec ...@@ -459,9 +462,12 @@ public class TCPReaderOneClient extends Thread implements IPeriodicTimeSignalRec
final int orderIndex = buffer.getInt(); final int orderIndex = buffer.getInt();
final int destinationId = buffer.getInt(); final int destinationId = buffer.getInt();
System.out.println("worker: sent remote - traceId: " + traceId);
try { try {
System.out.println("worker: sent remote: "
+ new SentRemoteCallRecord(timestamp, stringRegistry
.getStringFromId(destinationId), traceId, orderIndex,
hostApplicationMetadata).toString());
putInRingBuffer(new SentRemoteCallRecord(timestamp, putInRingBuffer(new SentRemoteCallRecord(timestamp,
stringRegistry.getStringFromId(destinationId), traceId, orderIndex, stringRegistry.getStringFromId(destinationId), traceId, orderIndex,
hostApplicationMetadata)); hostApplicationMetadata));
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment