19 #ifndef __OMNETPP_CMPICOMM_H
20 #define __OMNETPP_CMPICOMM_H
22 #include "omnetpp/cparsimcomm.h"
33 class SIM_API cMPICommunications :
public cParsimCommunications
36 cMPICommBuffer *recycledBuffer;
44 virtual cMPICommBuffer *doCreateCommBuffer();
55 virtual ~cMPICommunications();
62 virtual void init(
int numPartitions)
override;
67 virtual void shutdown()
override;
72 virtual int getNumPartitions()
const override;
77 virtual int getProcId()
const override;
82 virtual cCommBuffer *createCommBuffer()
override;
87 virtual void recycleCommBuffer(cCommBuffer *buffer)
override;
92 virtual void send(cCommBuffer *buffer,
int tag,
int destination)
override;
97 virtual void broadcast(cCommBuffer *buffer,
int tag)
override;
103 virtual bool receiveBlocking(
int filtTag, cCommBuffer *buffer,
int& receivedTag,
int& sourceProcId)
override;
110 virtual bool receiveNonblocking(
int filtTag, cCommBuffer *buffer,
int& receivedTag,
int& sourceProcId)
override;