DPL: fix leak in rate limiting

AliceO2Group · Mar 10, 2024 · a1497e7 · a1497e7
1 parent d43b949
commit a1497e7
Showing 1 changed file with 2 additions and 3 deletions.
diff --git 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;
   }
 }