diff --git a/Framework/Core/include/Framework/ComputingQuotaEvaluator.h b/Framework/Core/include/Framework/ComputingQuotaEvaluator.h index aee2e50c90e7f..17ce9c2ba3e65 100644 --- a/Framework/Core/include/Framework/ComputingQuotaEvaluator.h +++ b/Framework/Core/include/Framework/ComputingQuotaEvaluator.h @@ -32,7 +32,7 @@ class ComputingQuotaEvaluator { public: // Maximum number of offers this evaluator can hold - static constexpr int MAX_INFLIGHT_OFFERS = 16; + static constexpr int MAX_INFLIGHT_OFFERS = 32; ComputingQuotaEvaluator(ServiceRegistryRef ref); /// @a task the task which needs some quota /// @a request the resource request the @a task needs diff --git a/Framework/Core/include/Framework/ComputingQuotaOffer.h b/Framework/Core/include/Framework/ComputingQuotaOffer.h index b7707613bc19d..8d4420e7af2f5 100644 --- a/Framework/Core/include/Framework/ComputingQuotaOffer.h +++ b/Framework/Core/include/Framework/ComputingQuotaOffer.h @@ -84,7 +84,7 @@ using ComputingQuotaRequest = std::function&, ComputingQuotaStats&, std::function)>; +using ComputingQuotaConsumer = std::function&, ComputingQuotaStats&, std::function)>; } // namespace o2::framework diff --git a/Framework/Core/src/DataProcessor.cxx b/Framework/Core/src/DataProcessor.cxx index e9938a304b8a6..aef2455c8eb9d 100644 --- a/Framework/Core/src/DataProcessor.cxx +++ b/Framework/Core/src/DataProcessor.cxx @@ -123,7 +123,7 @@ void DataProcessor::doSend(DataSender& sender, ArrowContext& context, ServiceReg } static int64_t previousBytesSent = 0; auto disposeResources = [bs = context.bytesSent() - previousBytesSent](int taskId, - std::array& offers, + std::array& offers, ComputingQuotaStats& stats, std::function accountDisposed) { ComputingQuotaOffer disposed; diff --git a/Framework/Core/test/test_ComputingQuotaEvaluator.cxx b/Framework/Core/test/test_ComputingQuotaEvaluator.cxx index 0df58ae7fed08..afd252ec169d4 100644 --- a/Framework/Core/test/test_ComputingQuotaEvaluator.cxx +++ b/Framework/Core/test/test_ComputingQuotaEvaluator.cxx @@ -28,7 +28,7 @@ TEST_CASE("TestComputingQuotaEvaluator") }; ComputingQuotaConsumer dispose2MB = [bs = 2000000](int taskId, - std::array& offers, + std::array& offers, ComputingQuotaStats& stats, std::function accountDisposed) { ComputingQuotaOffer disposed; @@ -51,7 +51,7 @@ TEST_CASE("TestComputingQuotaEvaluator") }; ComputingQuotaConsumer dispose10MB = [bs = 10000000](int taskId, - std::array& offers, + std::array& offers, ComputingQuotaStats& stats, std::function accountDisposed) { ComputingQuotaOffer disposed;