MPIDirectCommunication.hpp

Go to the documentation of this file.

#ifndef PRECICE_NO_MPI
 
#pragma once
 
#include <mpi.h>
#include <set>
#include <stddef.h>
#include <string>
 
#include "com/MPICommunication.hpp"
#include "logging/Logger.hpp"
#include "precice/impl/Types.hpp"
#include "utils/Parallel.hpp"
#include "utils/assertion.hpp"
 
namespace precice {
namespace com {
class MPIDirectCommunication : public MPICommunication {
public:
  MPIDirectCommunication();
 
  virtual ~MPIDirectCommunication();
 
  virtual size_t getRemoteCommunicatorSize() override;
 
  virtual void acceptConnection(std::string const &acceptorName,
                                std::string const &requesterName,
                                std::string const &tag,
                                int                acceptorRank,
                                int                rankOffset = 0) override;
 
  virtual void acceptConnectionAsServer(std::string const &acceptorName,
                                        std::string const &requesterName,
                                        std::string const &tag,
                                        int                acceptorRank,
                                        int                requesterCommunicatorSize) override
  {
    PRECICE_ASSERT(false, "Not implemented!");
  }
 
  virtual void requestConnection(std::string const &acceptorName,
                                 std::string const &requesterName,
                                 std::string const &tag,
                                 int                requesterRank,
                                 int                requesterCommunicatorSize) override;
 
  virtual void requestConnectionAsClient(std::string const &  acceptorName,
                                         std::string const &  requesterName,
                                         std::string const &  tag,
                                         std::set<int> const &acceptorRanks,
                                         int                  requesterRank) override
  {
    PRECICE_ASSERT(false, "Not implemented!");
  }
 
  virtual void closeConnection() override;
 
  virtual void reduceSum(precice::span<double const> itemsToSend, precice::span<double> itemsToReceive, Rank primaryRank) override;
 
  virtual void reduceSum(precice::span<double const> itemsToSend, precice::span<double> itemsToReceive) override;
 
  virtual void reduceSum(int itemToSend, int &itemsToReceive, Rank primaryRank) override;
 
  virtual void reduceSum(int itemToSend, int &itemsToReceive) override;
 
  virtual void allreduceSum(precice::span<double const> itemsToSend, precice::span<double> itemsToReceive, Rank primaryRank) override;
 
  virtual void allreduceSum(precice::span<double const> itemsToSend, precice::span<double> itemsToReceive) override;
 
  virtual void allreduceSum(double itemToSend, double &itemsToReceive, Rank primaryRank) override;
 
  virtual void allreduceSum(double itemToSend, double &itemsToReceive) override;
 
  virtual void allreduceSum(int itemToSend, int &itemsToReceive, Rank primaryRank) override;
 
  virtual void allreduceSum(int itemToSend, int &itemsToReceive) override;
 
  virtual void broadcast(precice::span<const int> itemsToSend) override;
 
  virtual void broadcast(precice::span<int> itemsToReceive, Rank rankBroadcaster) override;
 
  virtual void broadcast(int itemToSend) override;
 
  virtual void broadcast(int &itemToReceive, Rank rankBroadcaster) override;
 
  virtual void broadcast(precice::span<const double> itemsToSend) override;
 
  virtual void broadcast(precice::span<double> itemsToReceive, Rank rankBroadcaster) override;
 
  virtual void broadcast(double itemToSend) override;
 
  virtual void broadcast(double &itemToReceive, Rank rankBroadcaster) override;
 
  virtual void broadcast(bool itemToSend) override;
 
  virtual void broadcast(bool &itemToReceive, Rank rankBroadcaster) override;
 
private:
  virtual MPI_Comm &communicator(Rank rank = 0) override;
 
  virtual Rank rank(int rank) override;
 
  logging::Logger _log{"com::MPIDirectCommunication"};
 
  utils::Parallel::CommStatePtr _commState = nullptr;
 
protected:
  virtual int adjustRank(Rank rank) const override;
};
 
} // namespace com
} // namespace precice
 
#endif // not PRECICE_NO_MPI