diff --git a/Framework/Core/src/ArrowSupport.cxx b/Framework/Core/src/ArrowSupport.cxx index 4a56f38344ef3..58880f33e6ee5 100644 --- a/Framework/Core/src/ArrowSupport.cxx +++ b/Framework/Core/src/ArrowSupport.cxx @@ -290,7 +290,7 @@ o2::framework::ServiceSpec ArrowSupport::arrowBackendSpec() LOGP(INFO, "Unused offer {}", unusedOfferedMemory); lastUnusedOfferedMemory = unusedOfferedMemory; } - // availableSharedMemory is the amount of memory which we know is available to be offered. + // availableSharedMemory is the amount of memory which we know is available to be offered. // We subtract the amount which we know was already offered but it's unused and we then balance how // much was created with how much was destroyed. availableSharedMemory = MAX_SHARED_MEMORY + ((totalBytesDestroyed - totalBytesCreated) / 1000000) - unusedOfferedMemory; @@ -325,12 +325,12 @@ o2::framework::ServiceSpec ArrowSupport::arrowBackendSpec() LOGP(INFO, "Message {}/{} is forwarded so we are not returning its memory.", dh->dataOrigin, dh->dataDescription); continue; } - LOGP(INFO, "Message {}/{} is being deleted. We will return {}MB.", dh->dataOrigin, dh->dataDescription, dh->payloadSize/1000000.); + LOGP(INFO, "Message {}/{} is being deleted. We will return {}MB.", dh->dataOrigin, dh->dataDescription, dh->payloadSize / 1000000.); totalBytes += dh->payloadSize; totalMessages += 1; } arrow->updateBytesDestroyed(totalBytes); - LOGP(INFO, "{}MB bytes being given back to reader, totaling {}MB", totalBytes/1000000., arrow->bytesDestroyed()/1000000.); + LOGP(INFO, "{}MB bytes being given back to reader, totaling {}MB", totalBytes / 1000000., arrow->bytesDestroyed() / 1000000.); arrow->updateMessagesDestroyed(totalMessages); auto& monitoring = ctx.services().get(); monitoring.send(Metric{(uint64_t)arrow->bytesDestroyed(), "arrow-bytes-destroyed"}.addTag(Key::Subsystem, monitoring::tags::Value::DPL)); diff --git a/Framework/Core/src/ComputingQuotaEvaluator.cxx b/Framework/Core/src/ComputingQuotaEvaluator.cxx index f8d977a9e22f4..8b8e4e4a1f3b4 100644 --- a/Framework/Core/src/ComputingQuotaEvaluator.cxx +++ b/Framework/Core/src/ComputingQuotaEvaluator.cxx @@ -169,9 +169,9 @@ void ComputingQuotaEvaluator::consume(int id, ComputingQuotaConsumer& consumer) using o2::monitoring::tags::Key; using o2::monitoring::tags::Value; // This will report how much of the offers has to be considered consumed. - // Notice that actual memory usage might be larger, because we can over + // Notice that actual memory usage might be larger, because we can over // allocate. - auto reportConsumedOffer = [&totalDisposedMemory = mTotalDisposedSharedMemory, &monitoring = mRegistry.get()](ComputingQuotaOffer const&accumulatedConsumed) { + auto reportConsumedOffer = [&totalDisposedMemory = mTotalDisposedSharedMemory, &monitoring = mRegistry.get()](ComputingQuotaOffer const& accumulatedConsumed) { totalDisposedMemory += accumulatedConsumed.sharedMemory; monitoring.send(Metric{(uint64_t)totalDisposedMemory, "shm-offer-consumed"}.addTag(Key::Subsystem, Value::DPL)); };