DPL: have resource accounting for analysis work with 200MB per reader (AliceO2Group#7141)

ktf · web-flow · commit 31771a6e274b · 2021-09-28T15:40:26.000+02:00
diff --git a/Framework/Core/src/ArrowSupport.cxx b/Framework/Core/src/ArrowSupport.cxx
@@ -237,7 +237,7 @@ o2::framework::ServiceSpec ArrowSupport::arrowBackendSpec()
                        static RateLimitingState lastReportedState = RateLimitingState::UNKNOWN;
                        static uint64_t lastReportTime = 0;
                        static int64_t MAX_SHARED_MEMORY = calculateAvailableSharedMemory(registry);
-                       constexpr int64_t MAX_QUANTUM_SHARED_MEMORY = 300;
+                       constexpr int64_t MAX_QUANTUM_SHARED_MEMORY = 100;
                        constexpr int64_t MIN_QUANTUM_SHARED_MEMORY = 50;
 
                        static int64_t availableSharedMemory = MAX_SHARED_MEMORY;
diff --git a/Framework/Core/src/ResourcePolicy.cxx b/Framework/Core/src/ResourcePolicy.cxx
@@ -19,7 +19,7 @@ namespace o2::framework
 std::vector<ResourcePolicy> ResourcePolicy::createDefaultPolicies()
 {
   return {
-    ResourcePolicyHelpers::sharedMemoryBoundTask("internal-dpl-aod-reader.*", 200000000),
+    ResourcePolicyHelpers::sharedMemoryBoundTask("internal-dpl-aod-reader.*", 150000000),
     ResourcePolicyHelpers::trivialTask(".*")};
 }
 

Original file line number	Diff line number	Diff line change
`@@ -19,7 +19,7 @@ namespace o2::framework`
`19`	`19`	`std::vector<ResourcePolicy> ResourcePolicy::createDefaultPolicies()`
`20`	`20`	`{`
`21`	`21`	`return {`
`22`		`- ResourcePolicyHelpers::sharedMemoryBoundTask("internal-dpl-aod-reader.*", 200000000),`
	`22`	`+ ResourcePolicyHelpers::sharedMemoryBoundTask("internal-dpl-aod-reader.*", 150000000),`
`23`	`23`	`ResourcePolicyHelpers::trivialTask(".*")};`
`24`	`24`	`}`
`25`	`25`