@@ -715,16 +715,16 @@ o2::framework::ServiceSpec
715
715
O2_SIGNPOST_EVENT_EMIT (data_processor_context, cid, " oldest_possible_timeslice" , " Queueing oldest possible timeslice %" PRIu64 " propagation for execution." ,
716
716
(uint64_t )oldestPossibleOutput.timeslice .value );
717
717
AsyncQueueHelpers::post (
718
- queue, AsyncTask{ .timeslice = TimesliceId{oldestPossibleTimeslice},
719
- .id = decongestion.oldestPossibleTimesliceTask ,
720
- .debounce = -1 , .callback = decongestionCallback}
721
- .user <DecongestionContext>(DecongestionContext{.ref = services, .oldestPossibleOutput = oldestPossibleOutput}));
718
+ queue, AsyncTask{.timeslice = TimesliceId{oldestPossibleTimeslice},
719
+ .id = decongestion.oldestPossibleTimesliceTask ,
720
+ .debounce = -1 ,
721
+ .callback = decongestionCallback}
722
+ .user <DecongestionContext>(DecongestionContext{.ref = services, .oldestPossibleOutput = oldestPossibleOutput}));
722
723
723
724
if (decongestion.orderedCompletionPolicyActive ) {
724
725
AsyncQueueHelpers::post (
725
- queue, AsyncTask{.timeslice = TimesliceId{oldestPossibleOutput.timeslice .value },.id = decongestion.oldestPossibleTimesliceTask , .debounce = -1 ,
726
- .callback = decongestionCallbackOrdered}
727
- .user <DecongestionContext>({.ref = services, .oldestPossibleOutput = oldestPossibleOutput}));
726
+ queue, AsyncTask{.timeslice = TimesliceId{oldestPossibleOutput.timeslice .value }, .id = decongestion.oldestPossibleTimesliceTask , .debounce = -1 , .callback = decongestionCallbackOrdered}
727
+ .user <DecongestionContext>({.ref = services, .oldestPossibleOutput = oldestPossibleOutput}));
728
728
} },
729
729
.kind = ServiceKind::Serial};
730
730
}
0 commit comments