Skip to content

Commit 45f621d

Browse files
authored
Avoid injecting data unexpectedly (#11995)
This protects the case of multiple pipelines.
1 parent 094c535 commit 45f621d

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

Framework/Core/src/ExternalFairMQDeviceProxy.cxx

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -281,6 +281,10 @@ void injectMissingData(fair::mq::Device& device, fair::mq::Parts& parts, std::ve
281281
firstDH = dh;
282282
}
283283
for (size_t pi = 0; pi < present.size(); ++pi) {
284+
// Consider uninvolved pipelines as present.
285+
if (routes[pi].timeslice == (dph->startTime % routes[pi].maxTimeslices)) {
286+
present[pi] = true;
287+
}
284288
if (present[pi]) {
285289
continue;
286290
}

0 commit comments

Comments
 (0)