cmpicomm.h

//=========================================================================
//  CMPICOMM.H - part of
//
//                     OMNeT++/OMNEST
//            Discrete System Simulation in C++
//
//=========================================================================
 
/*--------------------------------------------------------------*
  Copyright (C) 1992-2017 Andras Varga
  Copyright (C) 2006-2017 OpenSim Ltd.
 
  This file is distributed WITHOUT ANY WARRANTY. See the file
  `license' for details on this and other legal matters.
*--------------------------------------------------------------*/
 
#include "omnetpp/platdep/config.h"
 
#ifdef WITH_MPI
 
#ifndef __OMNETPP_CMPICOMM_H
#define __OMNETPP_CMPICOMM_H
 
#include "omnetpp/cparsimcomm.h"
 
namespace omnetpp {
 
class cMPICommBuffer;
 
class SIM_API cMPICommunications : public cParsimCommunications
{
  protected:
    cMPICommBuffer *recycledBuffer;
    int numPartitions;
    int myRank;
 
  protected:
    virtual cMPICommBuffer *doCreateCommBuffer();
 
  public:
    cMPICommunications();
 
    virtual ~cMPICommunications();
 
    virtual void init(int numPartitions) override;
 
    virtual void shutdown() override;
 
    virtual int getNumPartitions() const override;
 
    virtual int getProcId() const override;
 
    virtual cCommBuffer *createCommBuffer() override;
 
    virtual void recycleCommBuffer(cCommBuffer *buffer) override;
 
    virtual void send(cCommBuffer *buffer, int tag, int destination) override;
 
    virtual void broadcast(cCommBuffer *buffer, int tag) override;
 
    virtual bool receiveBlocking(int filtTag, cCommBuffer *buffer, int& receivedTag, int& sourceProcId) override;
 
    virtual bool receiveNonblocking(int filtTag, cCommBuffer *buffer,  int& receivedTag, int& sourceProcId) override;
};
 
}  // namespace omnetpp
 
 
#endif
 
#endif