From 401f56d5161e47bc4c8e405c1f63b040516cbe1a Mon Sep 17 00:00:00 2001
From: Christian Wulf <chw@informatik.uni-kiel.de>
Date: Thu, 7 Aug 2014 19:46:06 +0200
Subject: [PATCH] added TODO
---
.../examples/kiekerdays/KiekerLoadDriver.java | 15 ++++++++-------
1 file changed, 8 insertions(+), 7 deletions(-)
diff --git a/src/test/java/teetime/variant/methodcallWithPorts/examples/kiekerdays/KiekerLoadDriver.java b/src/test/java/teetime/variant/methodcallWithPorts/examples/kiekerdays/KiekerLoadDriver.java
index aeec0cb3..5fffebe5 100644
--- a/src/test/java/teetime/variant/methodcallWithPorts/examples/kiekerdays/KiekerLoadDriver.java
+++ b/src/test/java/teetime/variant/methodcallWithPorts/examples/kiekerdays/KiekerLoadDriver.java
@@ -132,13 +132,6 @@ public class KiekerLoadDriver {
try {
recordReceiver.connect();
- for (IMonitoringRecord record : records) {
- int clazzId = stringRegistry.get(record.getClass().getName());
- recordBuffer.putInt(clazzId);
- recordBuffer.putLong(record.getLoggingTimestamp());
- record.writeBytes(recordBuffer, stringRegistry);
- }
-
String hostname = "localhost";
int port = 10133;
System.out.println("Connecting to " + hostname + ":" + port);
@@ -147,6 +140,13 @@ public class KiekerLoadDriver {
try {
socketChannel.connect(new InetSocketAddress(hostname, port));
for (int i = 0; i < runs; i++) {
+ for (IMonitoringRecord record : records) {
+ // TODO increase trace id
+ int clazzId = stringRegistry.get(record.getClass().getName());
+ recordBuffer.putInt(clazzId);
+ recordBuffer.putLong(record.getLoggingTimestamp());
+ record.writeBytes(recordBuffer, stringRegistry);
+ }
recordBuffer.flip();
// System.out.println("position: " + recordBuffer.position());
// System.out.println("limit: " + recordBuffer.limit());
@@ -158,6 +158,7 @@ public class KiekerLoadDriver {
System.out.println(i); // NOPMD (System.out)
}
// System.out.println("writtenBytes (record): " + writtenBytes);
+ recordBuffer.clear();
}
} finally {
socketChannel.close();
--
GitLab