Skip to content

Commit 35a94db

Browse files
committed
DPL: fix accounting of consumed timeslices
1 parent d6b601b commit 35a94db

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

Framework/Core/src/DataProcessingDevice.cxx

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -250,7 +250,7 @@ void run_completion(uv_work_t* handle, int status)
250250
stats.totalConsumedTimeslices += accumulatedConsumed.timeslices;
251251

252252
dpStats.updateStats({static_cast<short>(ProcessingStatsId::SHM_OFFER_BYTES_CONSUMED), DataProcessingStats::Op::Set, stats.totalConsumedBytes});
253-
dpStats.updateStats({static_cast<short>(ProcessingStatsId::TIMESLICE_OFFER_NUMBER_CONSUMED), DataProcessingStats::Op::Set, stats.totalConsumedBytes});
253+
dpStats.updateStats({static_cast<short>(ProcessingStatsId::TIMESLICE_OFFER_NUMBER_CONSUMED), DataProcessingStats::Op::Set, stats.totalConsumedTimeslices});
254254
dpStats.processCommandQueue();
255255
assert(stats.totalConsumedBytes == dpStats.metrics[(short)ProcessingStatsId::SHM_OFFER_BYTES_CONSUMED]);
256256
assert(stats.totalConsumedTimeslices == dpStats.metrics[(short)ProcessingStatsId::TIMESLICE_OFFER_NUMBER_CONSUMED]);

0 commit comments

Comments
 (0)