From a1497e7427ef669d90f6103216413645d75da184 Mon Sep 17 00:00:00 2001
From: Giulio Eulisse <10544+ktf@users.noreply.github.com>
Date: Sun, 10 Mar 2024 00:47:05 +0100
Subject: [PATCH] DPL: fix leak in rate limiting

---
 Framework/Core/src/CommonDataProcessors.cxx | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/Framework/Core/src/CommonDataProcessors.cxx b/Framework/Core/src/CommonDataProcessors.cxx
index 79a31af04cdcd..593cb8d1ac1f8 100644
--- a/Framework/Core/src/CommonDataProcessors.cxx
+++ b/Framework/Core/src/CommonDataProcessors.cxx
@@ -581,8 +581,7 @@ void retryMetricCallback(uv_async_t* async)
   }
   fair::mq::MessagePtr payload(device->NewMessage());
   payload->Rebuild(&oldestPossingTimeslice, sizeof(int64_t), nullptr, nullptr);
-  auto* consumed = (size_t*)malloc(sizeof(size_t));
-  *consumed = oldestPossingTimeslice;
+  auto consumed = oldestPossingTimeslice;
 
   int64_t result = channel->second[0].Send(payload, 100);
   // If the sending worked, we do not retry.
@@ -592,7 +591,7 @@ void retryMetricCallback(uv_async_t* async)
     // data will still happen.
     uv_async_send(async);
   } else {
-    lastTimeslice = *consumed;
+    lastTimeslice = consumed;
   }
 }