DPL: Fix injectMissingData not always marking all inactive pipelines as present when exiting early due to allFound

Author: davidrohr

Framework/Core/src/ExternalFairMQDeviceProxy.cxx

@@ -279,10 +279,6 @@ void injectMissingData(fair::mq::Device& device, fair::mq::Parts& parts, std::ve
       LOG(error) << "unexpected nullptr found. Skipping message pair.";
       continue;
     }
-    // Copy the DataProcessingHeader from the first message.
-    if (dph == nullptr) {
-      dph = o2::header::get<DataProcessingHeader*>(parts.At(msgidx)->GetData());
-    }
     if (!dh) {
       LOG(error) << "data on input " << msgidx << " does not follow the O2 data model, DataHeader missing";
       if (msgidx > 0) {
@@ -296,6 +292,15 @@ void injectMissingData(fair::mq::Device& device, fair::mq::Parts& parts, std::ve
         doPrintSizes = 0;
       }
     }
+    // Copy the DataProcessingHeader from the first message.
+    if (dph == nullptr) {
+      dph = o2::header::get<DataProcessingHeader*>(parts.At(msgidx)->GetData());
+      for (size_t pi = 0; pi < present.size(); ++pi) {
+        if (routes[pi].timeslice != (dph->startTime % routes[pi].maxTimeslices)) {
+          present[pi] = true;
+        }
+      }
+    }
     for (size_t pi = 0; pi < present.size(); ++pi) {
       if (present[pi] && !doPrintSizes) {
         continue;