Skip to content

Commit 308118c

Browse files
committed
Add signpost for discarded messages
1 parent 98399e0 commit 308118c

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

Framework/Core/src/CommonServices.cxx

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -185,15 +185,16 @@ o2::framework::ServiceSpec CommonServices::streamContextSpec()
185185
auto& routes = processingContext.services().get<DeviceSpec const>().outputs;
186186
auto& timeslice = processingContext.services().get<TimingInfo>().timeslice;
187187
auto& messageContext = processingContext.services().get<MessageContext>();
188+
O2_SIGNPOST_ID_FROM_POINTER(cid, stream_context, service);
188189
// Do not report discarded messages as missing outputs.
189190
if (messageContext.dispatchState() == MessageContext::DispatchState::Discarded) {
191+
O2_SIGNPOST_EVENT_EMIT(stream_context, cid, "postProcessingCallbacks", "Output messages discarded.");
190192
return;
191193
}
192194
// Check if we never created any data for this timeslice
193195
// if we did not, but we still have didDispatched set to true
194196
// it means it was created out of band.
195197
bool userDidCreate = false;
196-
O2_SIGNPOST_ID_FROM_POINTER(cid, stream_context, service);
197198
for (size_t ri = 0; ri < routes.size(); ++ri) {
198199
if (stream->routeCreated[ri] == true && stream->routeDPLCreated[ri] == false) {
199200
userDidCreate = true;

0 commit comments

Comments
 (0)