Skip to content

Commit 6f26252

Browse files
committed
Please consider the following formatting changes
1 parent 5ade45c commit 6f26252

File tree

3 files changed

+4
-5
lines changed

3 files changed

+4
-5
lines changed

Framework/Core/src/ArrowSupport.cxx

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -453,8 +453,7 @@ o2::framework::ServiceSpec ArrowSupport::arrowBackendSpec()
453453
};
454454
static ResourceStats timesliceResourceStats{
455455
.enoughCount = shmResourceState.available - shmResourceSpec.minQuantum > 0 ? 1 : 0,
456-
.lowCount = shmResourceState.available - shmResourceSpec.minQuantum > 0 ? 0 : 1
457-
};
456+
.lowCount = shmResourceState.available - shmResourceSpec.minQuantum > 0 ? 0 : 1};
458457

459458
O2_LOG_ENABLE(rate_limiting);
460459
offerResources(timesliceResourceState, timesliceResourceSpec, timesliceResourceStats,

Framework/Core/src/CommonDataProcessors.cxx

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -252,7 +252,7 @@ DataProcessorSpec CommonDataProcessors::getScheduledDummySink(std::vector<InputS
252252
};
253253
callbacks.set<CallbackService::Id::DomainInfoUpdated>(domainInfoUpdated);
254254

255-
return adaptStateless([](DataProcessingStats &stats, TimesliceIndex &timesliceIndex) {
255+
return adaptStateless([](DataProcessingStats& stats, TimesliceIndex& timesliceIndex) {
256256
O2_SIGNPOST_ID_GENERATE(sid, rate_limiting);
257257
auto oldestPossingTimeslice = timesliceIndex.getOldestPossibleOutput().timeslice.value;
258258
O2_SIGNPOST_EVENT_EMIT(rate_limiting, sid, "run", "Consumed timeframes (processing) to be set to %zu.", oldestPossingTimeslice);

Framework/Core/src/DataProcessingDevice.cxx

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1585,12 +1585,12 @@ void DataProcessingDevice::Run()
15851585
} else {
15861586
if (schedulingStats.numberOfUnscheduledSinceLastScheduled > 100 ||
15871587
(uv_now(state.loop) - schedulingStats.lastScheduled) > 30000) {
1588-
O2_SIGNPOST_EVENT_EMIT_WARN(scheduling, sid, "Run",
1588+
O2_SIGNPOST_EVENT_EMIT_WARN(scheduling, sid, "Run",
15891589
"Not enough resources to schedule computation. %zu skipped so far. Last scheduled at %zu.",
15901590
schedulingStats.numberOfUnscheduledSinceLastScheduled.load(),
15911591
schedulingStats.lastScheduled.load());
15921592
} else {
1593-
O2_SIGNPOST_EVENT_EMIT(scheduling, sid, "Run",
1593+
O2_SIGNPOST_EVENT_EMIT(scheduling, sid, "Run",
15941594
"Not enough resources to schedule computation. %zu skipped so far. Last scheduled at %zu.",
15951595
schedulingStats.numberOfUnscheduledSinceLastScheduled.load(),
15961596
schedulingStats.lastScheduled.load());

0 commit comments

Comments
 (0)