CD_ParallelOpsImplem.H

Go to the documentation of this file.

/* chombo-discharge
 * Copyright © 2021 SINTEF Energy Research.
 * Please refer to Copyright.txt and LICENSE in the chombo-discharge root directory.
 */
 
#ifndef CD_ParallelOpsImplem_H
#define CD_ParallelOpsImplem_H
 
// Std includes
#include <limits>
 
// Chombo includes
#include <SPMD.H>
 
// Our includes
#include <CD_NamespaceHeader.H>
 
inline void
ParallelOps::barrier() noexcept
{
  CH_TIME("ParallelOps::barrier");
 
#ifdef CH_MPI
  MPI_Barrier(Chombo_MPI::comm);
#endif
}
 
inline std::pair<int, int>
ParallelOps::partition(const int a_N) noexcept
{
  CH_TIME("ParallelOps::partition");
 
#ifdef CH_MPI
  const int equalChunk = a_N / numProc();
  const int remainder  = a_N % numProc();
 
  int begin = procID() * equalChunk;
  int end   = begin + equalChunk - 1;
 
  // Remainder goes to last rank.
  if (procID() == numProc() - 1) {
    end += remainder;
  }
 
  return std::make_pair(begin, end);
#else
  return std::make_pair(0, a_N - 1);
#endif
}
 
inline Real
ParallelOps::min(const Real& a_input) noexcept
{
  CH_TIME("ParallelOps::min(Real)");
 
#ifdef CH_MPI
  Real ret = a_input;
 
  const int result = MPI_Allreduce(MPI_IN_PLACE, &ret, 1, MPI_CH_REAL, MPI_MIN, Chombo_MPI::comm);
 
  if (result != MPI_SUCCESS) {
    MayDay::Error("In file ParallelOps::min -- MPI communication error");
  }
 
  return ret;
#else
  return a_input;
#endif
}
 
inline int
ParallelOps::min(const int& a_input) noexcept
{
  CH_TIME("ParallelOps::min(int)");
 
#ifdef CH_MPI
  int ret = a_input;
 
  const int result = MPI_Allreduce(MPI_IN_PLACE, &ret, 1, MPI_INT, MPI_MIN, Chombo_MPI::comm);
 
  if (result != MPI_SUCCESS) {
    MayDay::Error("In file ParallelOps::min -- MPI communication error");
  }
  return ret;
#else
  return a_input;
#endif
}
 
inline long long int
ParallelOps::min(const long long int& a_input) noexcept
{
  CH_TIME("ParallelOps::min(long long int)");
 
#ifdef CH_MPI
  long long int ret = a_input;
 
  const int result = MPI_Allreduce(MPI_IN_PLACE, &ret, 1, MPI_LONG_LONG, MPI_MIN, Chombo_MPI::comm);
 
  if (result != MPI_SUCCESS) {
    MayDay::Error("In file ParallelOps::min -- MPI communication error");
  }
  return ret;
#else
  return a_input;
#endif
}
 
inline std::pair<Real, RealVect>
ParallelOps::min(const Real& a_val, const RealVect& a_pos) noexcept
{
  CH_TIME("ParallelOps::min(Real, RealVect)");
 
#ifdef CH_MPI
  const int nProc = numProc();
 
  Real  d = a_val;
  Real* D = new Real[nProc];
 
  Real  x = a_pos[0];
  Real* X = new Real[nProc];
 
  Real  y = a_pos[1];
  Real* Y = new Real[nProc];
 
#if CH_SPACEDIM == 3
  Real  z = a_pos[2];
  Real* Z = new Real[nProc];
#endif
 
  MPI_Allgather(&d, 1, MPI_CH_REAL, D, 1, MPI_CH_REAL, Chombo_MPI::comm);
  MPI_Allgather(&x, 1, MPI_CH_REAL, X, 1, MPI_CH_REAL, Chombo_MPI::comm);
  MPI_Allgather(&y, 1, MPI_CH_REAL, Y, 1, MPI_CH_REAL, Chombo_MPI::comm);
#if CH_SPACEDIM == 3
  MPI_Allgather(&z, 1, MPI_CH_REAL, Z, 1, MPI_CH_REAL, Chombo_MPI::comm);
#endif
 
  Real dRet = D[0];
  Real xRet = X[0];
  Real yRet = Y[0];
#if CH_SPACEDIM == 3
  Real zRet = Z[0];
#endif
 
  for (int i = 1; i < nProc; i++) {
    if (D[i] < dRet) {
      dRet = D[i];
      xRet = X[i];
      yRet = Y[i];
#if CH_SPACEDIM == 3
      zRet = Z[i];
#endif
    }
  }
 
  delete[] D;
  delete[] X;
  delete[] Y;
#if CH_SPACEDIM == 3
  delete[] Z;
#endif
 
  return std::make_pair(dRet, RealVect(D_DECL(xRet, yRet, zRet)));
#else
  return std::make_pair(a_val, a_pos);
#endif
}
 
inline Real
ParallelOps::max(const Real& a_input) noexcept
{
  CH_TIME("ParallelOps::max(Real)");
 
#ifdef CH_MPI
  Real ret = a_input;
 
  const int result = MPI_Allreduce(MPI_IN_PLACE, &ret, 1, MPI_CH_REAL, MPI_MAX, Chombo_MPI::comm);
  if (result != MPI_SUCCESS) {
    MayDay::Error("In file ParallelOps::max -- MPI communication error");
  }
 
  return ret;
#else
  return a_input;
#endif
}
 
inline int
ParallelOps::max(const int& a_input) noexcept
{
  CH_TIME("ParallelOps::max(int)");
 
#ifdef CH_MPI
  int ret = a_input;
 
  const int result = MPI_Allreduce(MPI_IN_PLACE, &ret, 1, MPI_INT, MPI_MAX, Chombo_MPI::comm);
 
  if (result != MPI_SUCCESS) {
    MayDay::Error("In file ParallelOps::max -- MPI communication error");
  }
  return ret;
#else
  return a_input;
#endif
}
 
inline long long
ParallelOps::max(const long long& a_input) noexcept
{
  CH_TIME("ParallelOps::max(long long)");
 
#ifdef CH_MPI
  long long ret = a_input;
 
  const int result = MPI_Allreduce(MPI_IN_PLACE, &ret, 1, MPI_LONG_LONG, MPI_MAX, Chombo_MPI::comm);
 
  if (result != MPI_SUCCESS) {
    MayDay::Error("In file ParallelOps::max -- MPI communication error");
  }
  return ret;
#else
  return a_input;
#endif
}
 
inline std::pair<Real, RealVect>
ParallelOps::max(const Real& a_val, const RealVect& a_pos) noexcept
{
  CH_TIME("ParallelOps::max(Real, RealVect)");
 
#ifdef CH_MPI
  const int nProc = numProc();
 
  Real  d = a_val;
  Real* D = new Real[nProc];
 
  Real  x = a_pos[0];
  Real* X = new Real[nProc];
 
  Real  y = a_pos[1];
  Real* Y = new Real[nProc];
 
#if CH_SPACEDIM == 3
  Real  z = a_pos[2];
  Real* Z = new Real[nProc];
#endif
 
  MPI_Allgather(&d, 1, MPI_CH_REAL, D, 1, MPI_CH_REAL, Chombo_MPI::comm);
  MPI_Allgather(&x, 1, MPI_CH_REAL, X, 1, MPI_CH_REAL, Chombo_MPI::comm);
  MPI_Allgather(&y, 1, MPI_CH_REAL, Y, 1, MPI_CH_REAL, Chombo_MPI::comm);
#if CH_SPACEDIM == 3
  MPI_Allgather(&z, 1, MPI_CH_REAL, Z, 1, MPI_CH_REAL, Chombo_MPI::comm);
#endif
 
  Real dRet = D[0];
  Real xRet = X[0];
  Real yRet = Y[0];
#if CH_SPACEDIM == 3
  Real zRet = Z[0];
#endif
 
  for (int i = 1; i < nProc; i++) {
    if (D[i] > dRet) {
      dRet = D[i];
      xRet = X[i];
      yRet = Y[i];
#if CH_SPACEDIM == 3
      zRet = Z[i];
#endif
    }
  }
 
  delete[] D;
  delete[] X;
  delete[] Y;
#if CH_SPACEDIM == 3
  delete[] Z;
#endif
 
  return std::make_pair(dRet, RealVect(D_DECL(xRet, yRet, zRet)));
#else
  return std::make_pair(a_val, a_pos);
#endif
}
 
inline std::pair<Real, int>
ParallelOps::maxRank(const Real& a_val) noexcept
{
  CH_TIME("ParallelOps::maxRank(Real)");
 
#ifdef CH_MPI
  const int nProc = numProc();
 
  Real* values = new Real[nProc];
 
  MPI_Allgather(&a_val, 1, MPI_CH_REAL, values, 1, MPI_CH_REAL, Chombo_MPI::comm);
 
  int  irank  = -1;
  Real maxVal = -std::numeric_limits<Real>::max();
 
  for (int i = 0; i < nProc; i++) {
    if (values[i] > maxVal) {
      irank  = i;
      maxVal = values[i];
    }
  }
 
  delete[] values;
 
  return std::make_pair(maxVal, irank);
#else
  return std::make_pair(a_val, 0);
#endif
}
 
inline std::pair<Real, int>
ParallelOps::minRank(const Real& a_val) noexcept
{
  CH_TIME("ParallelOps::minRank(Real)");
 
#ifdef CH_MPI
  const int nProc = numProc();
 
  Real* values = new Real[nProc];
 
  MPI_Allgather(&a_val, 1, MPI_CH_REAL, values, 1, MPI_CH_REAL, Chombo_MPI::comm);
 
  int  irank  = -1;
  Real maxVal = std::numeric_limits<Real>::max();
 
  for (int i = 0; i < nProc; i++) {
    if (values[i] < maxVal) {
      irank  = i;
      maxVal = values[i];
    }
  }
 
  delete[] values;
 
  return std::make_pair(maxVal, irank);
#else
  return std::make_pair(a_val, 0);
#endif
}
 
inline Real
ParallelOps::sum(const Real& a_value) noexcept
{
  CH_TIME("ParallelOps::sum(Real)");
 
#ifdef CH_MPI
  Real ret = 0.0;
 
  const int result = MPI_Allreduce(&a_value, &ret, 1, MPI_CH_REAL, MPI_SUM, Chombo_MPI::comm);
  if (result != MPI_SUCCESS) {
    MayDay::Error("In file ParallelOps::sum -- MPI communication error");
  }
 
  return ret;
#else
  return a_value;
#endif
}
 
inline int
ParallelOps::sum(const int& a_value) noexcept
{
  CH_TIME("ParallelOps::sum(Real)");
 
#ifdef CH_MPI
  int ret = 0;
 
  const int result = MPI_Allreduce(&a_value, &ret, 1, MPI_INT, MPI_SUM, Chombo_MPI::comm);
  if (result != MPI_SUCCESS) {
    MayDay::Error("In file ParallelOps::sum -- MPI communication error");
  }
 
  return ret;
#else
  return a_value;
#endif
}
 
inline long
ParallelOps::sum(const long& a_value) noexcept
{
  CH_TIME("ParallelOps::sum(long)");
 
#ifdef CH_MPI
  long ret = 0;
 
  const int result = MPI_Allreduce(&a_value, &ret, 1, MPI_LONG, MPI_SUM, Chombo_MPI::comm);
  if (result != MPI_SUCCESS) {
    MayDay::Error("In file ParallelOps::sum -- MPI communication error");
  }
 
  return ret;
#else
  return a_value;
#endif
}
 
inline long long
ParallelOps::sum(const long long& a_value) noexcept
{
  CH_TIME("ParallelOps::sum(long long)");
 
#ifdef CH_MPI
  long long ret = 0;
 
  const int result = MPI_Allreduce(&a_value, &ret, 1, MPI_LONG_LONG, MPI_SUM, Chombo_MPI::comm);
  if (result != MPI_SUCCESS) {
    MayDay::Error("In file ParallelOps::sum -- MPI communication error");
  }
 
  return ret;
#else
  return a_value;
#endif
}
 
inline unsigned long long
ParallelOps::sum(const unsigned long long& a_value) noexcept
{
  CH_TIME("ParallelOps::sum(unsigned long long)");
 
#ifdef CH_MPI
  unsigned long long ret = 0;
 
  const int result = MPI_Allreduce(&a_value, &ret, 1, MPI_UNSIGNED_LONG_LONG, MPI_SUM, Chombo_MPI::comm);
  if (result != MPI_SUCCESS) {
    MayDay::Error("In file ParallelOps::sum -- MPI communication error");
  }
 
  return ret;
#else
  return a_value;
#endif
}
 
inline void
ParallelOps::vectorSum(Vector<Real>& a_data) noexcept
{
  CH_TIME("ParallelOps::vectorSum(Real)");
 
#ifdef CH_MPI
  const int result = MPI_Allreduce(MPI_IN_PLACE, &(a_data[0]), a_data.size(), MPI_CH_REAL, MPI_SUM, Chombo_MPI::comm);
  if (result != MPI_SUCCESS) {
    MayDay::Error("In file ParallelOps::vectorSum -- MPI communication error");
  }
#endif
}
 
inline void
ParallelOps::vectorSum(Vector<int>& a_data) noexcept
{
  CH_TIME("ParallelOps::vectorSum(int)");
 
#ifdef CH_MPI
  const int result = MPI_Allreduce(MPI_IN_PLACE, &(a_data[0]), a_data.size(), MPI_INT, MPI_SUM, Chombo_MPI::comm);
  if (result != MPI_SUCCESS) {
    MayDay::Error("In file ParallelOps::vectorSum -- MPI communication error");
  }
#endif
}
 
inline void
ParallelOps::vectorSum(Vector<long int>& a_data) noexcept
{
  CH_TIME("ParallelOps::vectorSum(long int)");
 
#ifdef CH_MPI
  const int result = MPI_Allreduce(MPI_IN_PLACE, &(a_data[0]), a_data.size(), MPI_LONG, MPI_SUM, Chombo_MPI::comm);
  if (result != MPI_SUCCESS) {
    MayDay::Error("In file ParallelOps::vectorSum -- MPI communication error");
  }
#endif
}
 
inline void
ParallelOps::vectorSum(Vector<long long int>& a_data) noexcept
{
  CH_TIME("ParallelOps::vectorSum(long long int)");
 
#ifdef CH_MPI
  const int result = MPI_Allreduce(MPI_IN_PLACE, &(a_data[0]), a_data.size(), MPI_LONG_LONG, MPI_SUM, Chombo_MPI::comm);
  if (result != MPI_SUCCESS) {
    MayDay::Error("In file ParallelOps::vectorSum -- MPI communication error");
  }
#endif
}
 
inline Real
ParallelOps::average(const Real& a_val) noexcept
{
  CH_TIME("ParallelOps::average(Real)");
 
#ifdef CH_MPI
  return ParallelOps::sum(a_val) / numProc();
#else
  return a_val;
#endif
}
 
inline Real
ParallelOps::standardDeviation(const Real& a_value) noexcept
{
  CH_TIME("ParallelOps::standardDeviation(Real)");
 
#ifdef CH_MPI
  const int nProc = numProc();
 
  const Real average = ParallelOps::average(a_value);
 
  Real* values = new Real[nProc];
 
  MPI_Allgather(&a_value, 1, MPI_CH_REAL, values, 1, MPI_CH_REAL, Chombo_MPI::comm);
 
  Real sigma = 0.0;
  for (int i = 0; i < nProc; i++) {
    sigma += std::pow(values[i] - average, 2);
  }
 
  delete[] values;
 
  return sqrt(sigma / nProc);
#else
  return 0.0;
#endif
}
 
#include <CD_NamespaceFooter.H>
 
#endif