DPL: reduce chances to drop offers

Workaround. Proper fix coming.

Author: ktf

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

Framework/Core/include/Framework/ComputingQuotaOffer.h

@@ -84,7 +84,7 @@ using ComputingQuotaRequest = std::function<OfferScore(ComputingQuotaOffer const
 
 /// A consumer is a function which updates a given function removing the
 /// amount of resources which are considered as consumed.
-using ComputingQuotaConsumer = std::function<void(int id, std::array<ComputingQuotaOffer, 16>&, ComputingQuotaStats&, std::function<void(ComputingQuotaOffer const&, ComputingQuotaStats& stats)>)>;
+using ComputingQuotaConsumer = std::function<void(int id, std::array<ComputingQuotaOffer, 32>&, ComputingQuotaStats&, std::function<void(ComputingQuotaOffer const&, ComputingQuotaStats& stats)>)>;
 
 } // namespace o2::framework
 

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<ComputingQuotaOffer, 16>& offers,
+                                                                         std::array<ComputingQuotaOffer, 32>& offers,
                                                                          ComputingQuotaStats& stats,
                                                                          std::function<void(ComputingQuotaOffer const&, ComputingQuotaStats&)> accountDisposed) {
     ComputingQuotaOffer disposed;

Framework/Core/test/test_ComputingQuotaEvaluator.cxx

@@ -28,7 +28,7 @@ TEST_CASE("TestComputingQuotaEvaluator")
   };
 
   ComputingQuotaConsumer dispose2MB = [bs = 2000000](int taskId,
-                                                     std::array<ComputingQuotaOffer, 16>& offers,
+                                                     std::array<ComputingQuotaOffer, 32>& offers,
                                                      ComputingQuotaStats& stats,
                                                      std::function<void(ComputingQuotaOffer const&, ComputingQuotaStats&)> accountDisposed) {
     ComputingQuotaOffer disposed;
@@ -51,7 +51,7 @@ TEST_CASE("TestComputingQuotaEvaluator")
   };
 
   ComputingQuotaConsumer dispose10MB = [bs = 10000000](int taskId,
-                                                       std::array<ComputingQuotaOffer, 16>& offers,
+                                                       std::array<ComputingQuotaOffer, 32>& offers,
                                                        ComputingQuotaStats& stats,
                                                        std::function<void(ComputingQuotaOffer const&, ComputingQuotaStats&)> accountDisposed) {
     ComputingQuotaOffer disposed;