From 2ce5bdc0bc4fb88d22d5ce1609b724a7ee70a936 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Florian=20L=C3=BCke?= <f.lueke@mesytec.com>
Date: Fri, 27 Dec 2024 20:15:01 +0100
Subject: [PATCH] mana auto replay: report nng perf after the producer thread
 terminated

---
 src/tools/mana_auto_replay.cc | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git a/src/tools/mana_auto_replay.cc b/src/tools/mana_auto_replay.cc
index 7ba3cfc..e89d300 100644
--- a/src/tools/mana_auto_replay.cc
+++ b/src/tools/mana_auto_replay.cc
@@ -344,10 +344,6 @@ struct NngPairStrategy: public ProcessingStrategy
         }
 
         report();
-        spdlog::debug("NngPairStrategy: producerTx: {:.2f} MiB, {} messages",
-                      producerTx.bytes / (1024.0 * 1024), producerTx.messages);
-        spdlog::debug("NngPairStrategy: consumerRx: {:.2f} MiB, {} messages",
-                      consumerRx.bytes / (1024.0 * 1024), consumerRx.messages);
     }
 
     void run(ListfileContext &listfileContext, ParserContext &parserContext) override
@@ -366,6 +362,11 @@ struct NngPairStrategy: public ProcessingStrategy
 
         if (producerThread.joinable())
             producerThread.join();
+
+        spdlog::debug("NngPairStrategy: producerTx: {:.2f} MiB, {} messages",
+                      producerTx.bytes / (1024.0 * 1024), producerTx.messages);
+        spdlog::debug("NngPairStrategy: consumerRx: {:.2f} MiB, {} messages",
+                      consumerRx.bytes / (1024.0 * 1024), consumerRx.messages);
     }
 };