52 [[clang::map_mpi_datatype]]
55 [[clang::map_mpi_datatype]]
58 [[clang::map_mpi_datatype]]
61 [[clang::map_mpi_datatype]]
64 [[clang::map_mpi_datatype]]
67 [[clang::map_mpi_datatype]]
70 [[clang::map_mpi_datatype]]
73 [[clang::map_mpi_datatype]]
76 [[clang::map_mpi_datatype]]
79 [[clang::map_mpi_datatype]]
116 static void send(
const tarch::mpi::DoubleMessage& buffer,
int destination,
int tag, std::function<
void()> startCommunicationFunctor, std::function<
void()> waitFunctor, MPI_Comm communicator );
117 static void receive(
tarch::mpi::DoubleMessage& buffer,
int source,
int tag, std::function<
void()> startCommunicationFunctor, std::function<
void()> waitFunctor, MPI_Comm communicator );
145 #if !defined(__MPI_ATTRIBUTES_LANGUAGE_EXTENSION__)
static Rank & getInstance()
This operation returns the singleton instance.
Have to include this header, as I need access to the SYCL_EXTERNAL keyword.
static void sendAndPollDanglingMessages(const tarch::mpi::DoubleMessage &message, int destination, int tag, MPI_Comm communicator=tarch::mpi::Rank::getInstance().getCommunicator())
int getSenderRank() const
std::string toString() const
static MPI_Datatype getBoundaryExchangeDatatype()
static void freeBoundaryExchangeDatatype()
static MPI_Datatype getJoinDatatype()
static void send(const tarch::mpi::DoubleMessage &buffer, int destination, int tag, MPI_Comm communicator)
In DaStGen (the first version), I had a non-static version of the send as well as the receive.
static MPI_Datatype getMultiscaleDataExchangeDatatype()
static MPI_Datatype getGlobalCommunciationDatatype()
static MPI_Datatype Datatype
Whenever we use LLVM's MPI extension (DaStGe), we rely on lazy initialisation of the datatype.
DoubleMessage(double __value)
static void freeForkDatatype()
static void receive(tarch::mpi::DoubleMessage &buffer, int source, int tag, std::function< void()> startCommunicationFunctor, std::function< void()> waitFunctor, MPI_Comm communicator)
static void receiveAndPollDanglingMessages(tarch::mpi::DoubleMessage &message, int source, int tag, MPI_Comm communicator=tarch::mpi::Rank::getInstance().getCommunicator())
static void initDatatype()
Wrapper around getDatatype() to trigger lazy evaluation if we use the lazy initialisation.
DoubleMessage(const DoubleMessage ©)=default
DoubleMessage(ObjectConstruction)
static void shutdownDatatype()
Free the underlying MPI datatype.
static MPI_Datatype getForkDatatype()
Hands out MPI datatype if we work without the LLVM MPI extension.
void setValue(double value)
static void freeMultiscaleDataExchangeDatatype()
static void send(const tarch::mpi::DoubleMessage &buffer, int destination, int tag, std::function< void()> startCommunicationFunctor, std::function< void()> waitFunctor, MPI_Comm communicator)
Alternative to the other send() where I trigger a non-blocking send an then invoke the functor until ...
int _senderDestinationRank
static void receive(tarch::mpi::DoubleMessage &buffer, int source, int tag, MPI_Comm communicator)
static void freeGlobalCommunciationDatatype()
static void freeJoinDatatype()