IntraComm.hpp

Go to the documentation of this file.

#pragma once
 
#include <Eigen/Core>
 
#include "boost/range/irange.hpp"
#include "com/SharedPointer.hpp"
#include "logging/Logger.hpp"
#include "precice/impl/Types.hpp"
#include "precice/span.hpp"
 
namespace precice {
namespace logging {
class Logger;
} // namespace logging
 
namespace utils {
 
class IntraComm {
public:
  static void configure(Rank rank, int size);
 
  static Rank getRank();
 
  static int getSize();
 
  static com::PtrCommunication &getCommunication()
  {
    return _communication;
  }
 
  static auto allSecondaryRanks()
  {
    return boost::irange(1, _size);
  }
 
  static auto allRanks()
  {
    return boost::irange(0, _size);
  }
 
  static bool isPrimary();
 
  static bool isSecondary();
 
  static bool isParallel();
 
  static double l2norm(const Eigen::VectorXd &vec);
 
  // The dot product of 2 vectors is calculated on distributed data.
  static double dot(const Eigen::VectorXd &vec1, const Eigen::VectorXd &vec2);
 
  static void reset();
 
  static void reduceSum(precice::span<const double> sendData, precice::span<double> rcvData);
 
  static void reduceSum(const int &sendData, int &rcvData);
 
  static void reduceSum(const double &sendData, double &rcvData);
 
  static void allreduceSum(precice::span<const double> sendData, precice::span<double> rcvData);
 
  static void allreduceSum(double &sendData, double &rcvData);
 
  static void allreduceSum(int &sendData, int &rcvData);
 
  static void broadcast(bool &value);
 
  static void broadcast(double &value);
 
  static void broadcast(int &value);
 
  static void broadcast(precice::span<double> values);
 
  static void synchronize();
 
  static void barrier();
 
private:
  static logging::Logger _log;
 
  static Rank _rank;
 
  static int _size;
 
  static bool _isPrimaryRank;
 
  static bool _isSecondaryRank;
 
  static com::PtrCommunication _communication;
};
 
} // namespace utils
} // namespace precice