Skip to content

Commit b7122c1

Browse files
committed
DPL: ensure dummy sink is added with correct rate limiting configuration
* If there is a TFN/TFF source, sink has to catch these messages to be at the topology end * If the TFN/TFF source is aod-producer, the rate limiting config should be with out-of-band channel instead of scheduler
1 parent 0a6ade3 commit b7122c1

1 file changed

Lines changed: 6 additions & 3 deletions

File tree

Framework/Core/src/WorkflowHelpers.cxx

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -627,12 +627,15 @@ void WorkflowHelpers::injectServiceDevices(WorkflowSpec& workflow, ConfigContext
627627
// Use the new dummy sink when the AOD reader is there
628628
O2_SIGNPOST_ID_GENERATE(sid, workflow_helpers);
629629
if (tfnsource != workflow.end()) {
630-
O2_SIGNPOST_EVENT_EMIT(workflow_helpers, sid, "injectServiceDevices", "Injecting scheduled dummy sink");
631-
// if there is a tfnsource, make sure the sink gets TFN/TFF
632630
DataSpecUtils::updateInputList(ignored, InputSpec{"tfn", "TFN", "TFNumber", 0, Lifetime::Sporadic});
633631
DataSpecUtils::updateInputList(ignored, InputSpec{"tff", "TFF", "TFFilename", 0, Lifetime::Sporadic});
632+
}
633+
634+
if (tfnsource != workflow.end() && !tfnsource->name.starts_with("aod-producer-workflow")) { // any tfnsource except the aod-producer should use scheduled sink
635+
O2_SIGNPOST_EVENT_EMIT(workflow_helpers, sid, "injectServiceDevices", "Injecting scheduled dummy sink");
636+
// if there is a tfnsource, make sure the sink gets TFN/TFF
634637
extraSpecs.push_back(CommonDataProcessors::getScheduledDummySink(ignored));
635-
} else {
638+
} else { // if there is no tfn source or if that source is aod-producer-workflow, out-of-band channel is used to propagate the number of consumed timeframes
636639
O2_SIGNPOST_EVENT_EMIT(workflow_helpers, sid, "injectServiceDevices", "Injecting rate limited dummy sink");
637640
std::string rateLimitingChannelConfigOutput;
638641
if (rateLimitingIPCID != -1) {

0 commit comments

Comments
 (0)