From 6f36b307257fafcbfe90dc3b7a98921eec89c748 Mon Sep 17 00:00:00 2001
From: Felix Weiglhofer <weiglhofer@fias.uni-frankfurt.de>
Date: Tue, 3 Oct 2023 16:08:05 +0200
Subject: [PATCH] algo: Annotate Unpack timers to calculate throughput.

---
 algo/unpack/Unpack.cxx | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/algo/unpack/Unpack.cxx b/algo/unpack/Unpack.cxx
index 7b6559b4db..e5698e0c1f 100644
--- a/algo/unpack/Unpack.cxx
+++ b/algo/unpack/Unpack.cxx
@@ -177,6 +177,7 @@ namespace cbm::algo
     genericMonitor.fNumBytes += sizeBytes;
 
     xpu::push_timer("Unpack");
+    xpu::t_add_bytes(sizeBytes);
 #pragma omp parallel for schedule(dynamic)
     for (size_t i = 0; i < numMs; i++) {
       auto result = algos.at(msEqIds[i])(msContent[i], msDesc[i], ts.start_time());
@@ -185,16 +186,16 @@ namespace cbm::algo
     }
     xpu::pop_timer();
 
+    xpu::push_timer("Resize");
     size_t nDigisTotal = 0;
     for (const auto& digis : msDigis) {
       nDigisTotal += digis.size();
     }
-
-    xpu::push_timer("Resize");
     digisOut.resize(nDigisTotal);
     xpu::pop_timer();
 
     xpu::push_timer("Merge");
+    xpu::t_add_bytes(nDigisTotal * sizeof(Digi));
 #pragma omp parallel for schedule(dynamic)
     for (unsigned int i = 0; i < numMs; i++) {
       unsigned int offset = 0;
-- 
GitLab