From 2a0617617704499f43073285fb204f6b0d843930 Mon Sep 17 00:00:00 2001
From: Giulio Eulisse <10544+ktf@users.noreply.github.com>
Date: Mon, 25 Apr 2022 16:50:15 +0200
Subject: [PATCH] DPL: only send the oldest possible timeframe to DPL channels

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

diff --git a/Framework/Core/src/DataProcessingDevice.cxx b/Framework/Core/src/DataProcessingDevice.cxx
index f0ae192692892..61d18e9e4ba49 100644
--- a/Framework/Core/src/DataProcessingDevice.cxx
+++ b/Framework/Core/src/DataProcessingDevice.cxx
@@ -1646,9 +1646,11 @@ bool DataProcessingDevice::tryDispatchComputation(DataProcessorContext& context,
 
       // The oldest possible timeslice for a forwarded message
       // is conservatively the one of the device doing the forwarding.
-      auto oldestTimeslice = timesliceIndex.getOldestPossibleOutput();
-      DataProcessingHelpers::sendOldestPossibleTimeframe(channel, oldestTimeslice.timeslice.value);
-      LOGP(debug, "Forwarding to channel {} oldest possible timeslice {}", spec->forwards[fi].channel, oldestTimeslice.timeslice.value);
+      if (spec->forwards[fi].channel.rfind("from_", 0) == 0) {
+        auto oldestTimeslice = timesliceIndex.getOldestPossibleOutput();
+        DataProcessingHelpers::sendOldestPossibleTimeframe(channel, oldestTimeslice.timeslice.value);
+        LOGP(debug, "Forwarding to channel {} oldest possible timeslice {}", spec->forwards[fi].channel, oldestTimeslice.timeslice.value);
+      }
     }
   };