Skip to content

Commit 4e720b0

Browse files
committed
DPL: add debug statement for offers
1 parent abdd7f1 commit 4e720b0

1 file changed

Lines changed: 5 additions & 2 deletions

File tree

Framework/Core/src/ComputingQuotaEvaluator.cxx

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -102,11 +102,14 @@ bool ComputingQuotaEvaluator::selectOffer(int task, ComputingQuotaRequest const&
102102
}
103103
dpStats.updateStats({static_cast<short>(ProcessingStatsId::RESOURCES_SATISFACTORY), DataProcessingStats::Op::Add, 1});
104104
} else {
105-
O2_SIGNPOST_START(quota, sid, "summary", "Not enough resources to select offers.");
106-
dpStats.updateStats({static_cast<short>(ProcessingStatsId::RESOURCES_MISSING), DataProcessingStats::Op::Add, 1});
107105
if (result.size()) {
106+
O2_SIGNPOST_START(quota, sid, "summary", "Not enough resources: accumulated %zu partial offers providing cpu=%d, memory=%lld MB, shared memory=%lld MB, timeslices=%lld, but still insufficient.",
107+
result.size(), totalOffer.cpu, totalOffer.memory / 1000000, totalOffer.sharedMemory / 1000000, totalOffer.timeslices);
108108
dpStats.updateStats({static_cast<short>(ProcessingStatsId::RESOURCES_INSUFFICIENT), DataProcessingStats::Op::Add, 1});
109+
} else {
110+
O2_SIGNPOST_START(quota, sid, "summary", "Not enough resources: no suitable offers found (all offers were invalid, expired, or owned by other tasks).");
109111
}
112+
dpStats.updateStats({static_cast<short>(ProcessingStatsId::RESOURCES_MISSING), DataProcessingStats::Op::Add, 1});
110113
}
111114
if (stats.invalidOffers.size()) {
112115
O2_SIGNPOST_EVENT_EMIT(quota, sid, "summary", "The following offers were invalid: %s", fmt::format("{}", fmt::join(stats.invalidOffers, ", ")).c_str());

0 commit comments

Comments
 (0)