From 7c1e3f483317b5b635f6f1fd0659fc2bf2cb3599 Mon Sep 17 00:00:00 2001
From: Giulio Eulisse <10544+ktf@users.noreply.github.com>
Date: Tue, 24 Aug 2021 00:22:56 +0200
Subject: [PATCH] DPL: correctly report consumed shared memory

---
 Framework/Core/src/DataProcessor.cxx | 1 +
 1 file changed, 1 insertion(+)

diff --git a/Framework/Core/src/DataProcessor.cxx b/Framework/Core/src/DataProcessor.cxx
index ece774e34f540..54c2262058a5a 100644
--- a/Framework/Core/src/DataProcessor.cxx
+++ b/Framework/Core/src/DataProcessor.cxx
@@ -119,6 +119,7 @@ void DataProcessor::doSend(FairMQDevice& device, ArrowContext& context, ServiceR
       int64_t toRemove = std::min((int64_t)bytesSent, offer.sharedMemory);
       offer.sharedMemory -= toRemove;
       bytesSent -= toRemove;
+      disposed.sharedMemory += toRemove;
       if (bytesSent <= 0) {
         break;
       }