Skip to content

Commit bd6b250

Browse files
fixup! Make MessageSet the owner of FairMQMessage objects in a linear vector
1 parent c8cd9de commit bd6b250

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

Framework/Core/src/DataRelayer.cxx

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -591,7 +591,7 @@ std::vector<o2::framework::MessageSet> DataRelayer::getInputsForTimeslice(Timesl
591591
// FIXME: what happens when we have enough timeslices to hit the invalid one?
592592
auto invalidateCacheFor = [&numInputTypes, &cachedStateMetrics = mCachedStateMetrics, &index, &cache](TimesliceSlot s) {
593593
for (size_t ai = s.index * numInputTypes, ae = ai + numInputTypes; ai != ae; ++ai) {
594-
//assert(std::accumulate(cache[ai].begin(), cache[ai].end(), true, [](bool result, auto const& element) { return result && element.header().get() == nullptr && element.payload().get() == nullptr; }));
594+
assert(std::accumulate(cache[ai].messages.begin(), cache[ai].messages.end(), true, [](bool result, auto const& element) { return result && element.get() == nullptr; }));
595595
cache[ai].clear();
596596
}
597597
index.markAsInvalid(s);

0 commit comments

Comments
 (0)