From 8e41a2ff27cfba7cb11622ce1a30615c2acfee9e Mon Sep 17 00:00:00 2001
From: Florian Fittkau <ffi@informatik.uni-kiel.de>
Date: Thu, 13 Feb 2014 21:11:54 +0100
Subject: [PATCH] debug for remote
---
.../reader/TCPReaderOneClient.java | 12 +++++++++---
1 file changed, 9 insertions(+), 3 deletions(-)
diff --git a/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java b/src/explorviz/live_trace_processing/reader/TCPReaderOneClient.java
index 4705d16..3fe9a59 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));
--
GitLab