Skip to content

Commit e802990

Browse files
authored
DPL Analysis: keep reading after a skipped timeframe (#15952)
Returning after a skip leaked the callback's timeslice offer, which eventually starved the reader.
1 parent 549e1cc commit e802990

1 file changed

Lines changed: 6 additions & 1 deletion

File tree

‎Framework/AnalysisSupport/src/AODJAlienReaderHelpers.cxx‎

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -410,7 +410,12 @@ AlgorithmSpec AODJAlienReaderHelpers::rootFileReaderCallback(ConfigContext const
410410
transitionTo(TFReaderState::READ_FIRST_TABLE_FROM_NEXT_FILE);
411411
break;
412412
case TFReaderState::INVALID_TIMEFRAME:
413-
return;
413+
// Returning would leak this callback's timeslice offer, so read the next timeframe.
414+
messageContext.clear();
415+
++ntf;
416+
routeIndex = 0;
417+
transitionTo(TFReaderState::READ_FIRST_TABLE);
418+
break;
414419
case TFReaderState::TIMEFRAME_READ:
415420
break;
416421
}

0 commit comments

Comments
 (0)