Skip to content

Commit 77ec0e2

Browse files
davidrohrBenedikt Volkel
authored andcommitted
DPL: Throw error messages when the oldestPossibleTimeframe is incorrectly decreased
(cherry picked from commit 725befe)
1 parent 883464c commit 77ec0e2

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

Framework/Core/src/TimesliceIndex.cxx

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -171,6 +171,9 @@ TimesliceIndex::OldestInputInfo TimesliceIndex::setOldestPossibleInput(Timeslice
171171
} else {
172172
O2_SIGNPOST_EVENT_EMIT(timeslice_index, tid, "setOldestPossibleInput", "No change in oldest possible input");
173173
}
174+
if (mOldestPossibleInput.timeslice.value > result.timeslice.value) {
175+
LOG(error) << "DPL internal error - oldestPossibleInput of channel " << channel.value << ": " << getChannelInfo(channel).channel->GetName().c_str() << " decreased from " << mOldestPossibleOutput.timeslice.value << " to " << result.timeslice.value;
176+
}
174177
mOldestPossibleInput = result;
175178
return mOldestPossibleInput;
176179
}
@@ -220,6 +223,9 @@ TimesliceIndex::OldestOutputInfo TimesliceIndex::updateOldestPossibleOutput()
220223
mOldestPossibleOutput.timeslice.value, result.timeslice.value);
221224
}
222225
}
226+
if (mOldestPossibleOutput.timeslice.value > result.timeslice.value) {
227+
LOG(error) << "DPL internal error - oldestPossibleOutput decreased from " << mOldestPossibleOutput.timeslice.value << " to " << result.timeslice.value;
228+
}
223229
mOldestPossibleOutput = result;
224230

225231
return result;

0 commit comments

Comments
 (0)