Skip to content

Commit cd1cb0d

Browse files
committed
DPL: have helper which returns true if running online
1 parent ab2ef08 commit cd1cb0d

File tree

3 files changed

+17
-5
lines changed

3 files changed

+17
-5
lines changed

Framework/Core/include/Framework/DefaultsHelpers.h

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,8 @@ enum struct DeploymentMode;
1818

1919
struct DefaultsHelpers {
2020
static DeploymentMode deploymentMode();
21+
/// @true if running online
22+
static bool onlineDeploymentMode();
2123
/// get max number of timeslices in the queue
2224
static unsigned int pipelineLength();
2325
};

Framework/Core/src/CommonServices.cxx

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -848,8 +848,7 @@ o2::framework::ServiceSpec CommonServices::dataProcessingStats()
848848
bool enableDebugMetrics = true;
849849
#endif
850850
bool arrowAndResourceLimitingMetrics = false;
851-
DeploymentMode deploymentMode = DefaultsHelpers::deploymentMode();
852-
if (deploymentMode != DeploymentMode::OnlineDDS && deploymentMode != DeploymentMode::OnlineECS && deploymentMode != DeploymentMode::OnlineAUX && deploymentMode != DeploymentMode::FST) {
851+
if (!DefaultsHelpers::onlineDeploymentMode() && DefaultsHelpers::deploymentMode() != DeploymentMode::FST) {
853852
arrowAndResourceLimitingMetrics = true;
854853
}
855854
// Input proxies should not report cpu_usage_fraction,
@@ -1243,8 +1242,7 @@ std::vector<ServiceSpec> CommonServices::defaultServices(std::string extraPlugin
12431242
objectCache(),
12441243
ccdbSupportSpec()};
12451244

1246-
DeploymentMode deploymentMode = DefaultsHelpers::deploymentMode();
1247-
if (deploymentMode != DeploymentMode::OnlineDDS && deploymentMode != DeploymentMode::OnlineECS && deploymentMode != DeploymentMode::OnlineAUX && deploymentMode != DeploymentMode::FST) {
1245+
if (!DefaultsHelpers::onlineDeploymentMode() && DefaultsHelpers::deploymentMode() != DeploymentMode::FST) {
12481246
specs.push_back(ArrowSupport::arrowBackendSpec());
12491247
}
12501248
specs.push_back(CommonMessageBackends::fairMQBackendSpec());
@@ -1253,7 +1251,7 @@ std::vector<ServiceSpec> CommonServices::defaultServices(std::string extraPlugin
12531251

12541252
std::string loadableServicesStr = extraPlugins;
12551253
// Do not load InfoLogger by default if we are not at P2.
1256-
if (deploymentMode == DeploymentMode::OnlineDDS || deploymentMode == DeploymentMode::OnlineECS || deploymentMode == DeploymentMode::OnlineAUX) {
1254+
if (DefaultsHelpers::onlineDeploymentMode()) {
12571255
if (loadableServicesStr.empty() == false) {
12581256
loadableServicesStr += ",";
12591257
}

Framework/Core/src/DefaultsHelpers.cxx

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -64,4 +64,16 @@ DeploymentMode DefaultsHelpers::deploymentMode()
6464
return retVal;
6565
}
6666

67+
bool DefaultsHelpers::onlineDeploymentMode()
68+
{
69+
switch (DefaultsHelpers::deploymentMode()) {
70+
case DeploymentMode::OnlineAUX:
71+
case DeploymentMode::OnlineECS:
72+
case DeploymentMode::OnlineDDS:
73+
return true;
74+
default:
75+
return false;
76+
}
77+
}
78+
6779
} // namespace o2::framework

0 commit comments

Comments
 (0)