DPL: only send the oldest possible timeframe to DPL channels

AliceO2Group · Apr 25, 2022 · 2a06176 · 2a06176
1 parent b6e0538
commit 2a06176
Showing 1 changed file with 5 additions and 3 deletions.
diff --git 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);
+      }
     }
   };