DefaultsHelpers.cxx

Go to the documentation of this file.

// Copyright 2019-2020 CERN and copyright holders of ALICE O2.
// See https://alice-o2.web.cern.ch/copyright for details of the copyright holders.
// All rights not expressly granted are reserved.
//
// This software is distributed under the terms of the GNU General Public
// License v3 (GPL Version 3), copied verbatim in the file "COPYING".
//
// In applying this license CERN does not waive the privileges and immunities
// granted to it by virtue of its status as an Intergovernmental Organization
// or submit itself to any jurisdiction.
 
#include "Framework/DefaultsHelpers.h"
#include "Framework/DataTakingContext.h"
#include <cstdlib>
#include <cstring>
#include <stdexcept>
 
namespace o2::framework
{
 
unsigned int DefaultsHelpers::pipelineLength()
{
  static bool override = getenv("DPL_DEFAULT_PIPELINE_LENGTH");
  if (override) {
    static unsigned int retval = atoi(getenv("DPL_DEFAULT_PIPELINE_LENGTH"));
    return retval;
  }
  DeploymentMode deploymentMode = DefaultsHelpers::deploymentMode();
  // just some reasonable numers
  // The number should really be tuned at runtime for each processor.
  if (deploymentMode == DeploymentMode::OnlineDDS || deploymentMode == DeploymentMode::OnlineECS || deploymentMode == DeploymentMode::FST) {
    return 512;
  } else {
    return 64;
  }
}
 
static DeploymentMode getDeploymentMode_internal()
{
  char* explicitMode = getenv("O2_DPL_DEPLOYMENT_MODE");
  if (explicitMode != nullptr) {
    if (strcmp(explicitMode, "OnlineDDS") == 0) {
      return DeploymentMode::OnlineDDS;
    } else if (strcmp(explicitMode, "OnlineECS") == 0) {
      return DeploymentMode::OnlineECS;
    } else if (strcmp(explicitMode, "OnlineAUX") == 0) {
      return DeploymentMode::OnlineAUX;
    } else if (strcmp(explicitMode, "Local") == 0) {
      return DeploymentMode::Local;
    } else if (strcmp(explicitMode, "Grid") == 0) {
      return DeploymentMode::Grid;
    } else if (strcmp(explicitMode, "FST") == 0) {
      return DeploymentMode::FST;
    } else {
      throw std::runtime_error("Invalid deployment mode");
    }
  }
  return getenv("DDS_SESSION_ID") != nullptr ? DeploymentMode::OnlineDDS : (getenv("OCC_CONTROL_PORT") != nullptr ? DeploymentMode::OnlineECS : (getenv("ALIEN_PROC_ID") != nullptr ? DeploymentMode::Grid : (getenv("ALICE_O2_FST") ? DeploymentMode::FST : (DeploymentMode::Local))));
}
 
DeploymentMode DefaultsHelpers::deploymentMode()
{
  static DeploymentMode retVal = getDeploymentMode_internal();
  return retVal;
}
 
bool DefaultsHelpers::onlineDeploymentMode()
{
  switch (DefaultsHelpers::deploymentMode()) {
    case DeploymentMode::OnlineAUX:
    case DeploymentMode::OnlineECS:
    case DeploymentMode::OnlineDDS:
      return true;
    default:
      return false;
  }
}
 
} // namespace o2::framework