From 3b184a0c2381b4a1de55b8c564f108c516516197 Mon Sep 17 00:00:00 2001
From: Enrico Olivelli <eolivelli@gmail.com>
Date: Sat, 29 Jan 2022 12:11:14 +0100
Subject: [PATCH] Pulsar: report latency in ns for Payload RRT

---
 .../io/nosqlbench/driver/pulsar/ops/PulsarConsumerOp.java     | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/PulsarConsumerOp.java b/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/PulsarConsumerOp.java
index 93766a33a..783a8b4c2 100644
--- a/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/PulsarConsumerOp.java
+++ b/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/PulsarConsumerOp.java
@@ -279,7 +279,9 @@ public class PulsarConsumerOp implements PulsarOp {
                 }
             }
             if (extractedSendTime != null) {
-                long delta = System.currentTimeMillis() - extractedSendTime;
+                // fallout expects latencies in "ns" and not in "ms"
+                long delta = TimeUnit.MILLISECONDS
+                    .toNanos(System.currentTimeMillis() - extractedSendTime);
                 payloadRttHistogram.update(delta);
             }
         }