Method checkEnvVariables

src/Parallel/Pin.cpp:148–192

}

void Pinning::checkEnvVariables() {
#ifndef __APPLE__
  const auto rank = MPI::mpi.rank();
  if (const char* envVariable = std::getenv("SEISSOL_FREE_CPUS_MASK")) {
    auto parsedResult = seissol::IntegerMaskParser::parse(std::string(envVariable));
    if (parsedResult) {
      parsedFreeCPUsMask = parsedResult.value();

      bool isMaskGood{true};
      const auto numLocalProcesses = MPI::mpi.sharedMemMpiSize();
      if (numLocalProcesses > static_cast<int>(parsedFreeCPUsMask.size())) {
        logInfo(rank) << "There are more communication (and/or output-writing) threads"
                      << "to pin than locations defined in `SEISSOL_FREE_CPUS_MASK`";

        isMaskGood = false;
      } else {
        const auto maxCpuId = get_nprocs();
        for (auto localProcessId = 0; localProcessId < static_cast<int>(parsedFreeCPUsMask.size());
             ++localProcessId) {
          for (auto cpu : parsedFreeCPUsMask[localProcessId]) {
            if (cpu > maxCpuId) {
              logInfo(rank) << "Free cpu mask of the local process" << localProcessId
                            << "is out of bounds. CPU/core id" << cpu << "exceeds max. value"
                            << maxCpuId;
              isMaskGood = false;
              break;
            }
          }
        }
      }

      if (isMaskGood) {
        logInfo(rank) << "Binding free cpus according to `SEISSOL_FREE_CPUS_MASK` env. variable.";
      } else {
        logWarning(rank) << "Ignoring `SEISSOL_FREE_CPUS_MASK` env. variable.";
        logWarning(rank) << "`SEISSOL_FREE_CPUS_MASK` Format:"
                         << "(<int>|<range: int-int>|<list: {int,+}>),+";
        parsedFreeCPUsMask = IntegerMaskParser::MaskType{};
      }
    } else {
      logWarning(rank) << "Failed to parse `SEISSOL_FREE_CPUS_MASK` env. variable";
    }
  }
#endif // __APPLE__
}

CpuMask Pinning::getWorkerUnionMask() {
#ifndef __APPLE__