cmpicomm.h

//=========================================================================
//  CMPICOMM.H - part of
//
//                  OMNeT++/OMNEST
//           Discrete System Simulation in C++
//
//   Written by:  Andras Varga, 2003
//
//=========================================================================

/*--------------------------------------------------------------*
  Copyright (C) 2003-2005 Andras Varga
  Monash University, Dept. of Electrical and Computer Systems Eng.
  Melbourne, Australia

  This file is distributed WITHOUT ANY WARRANTY. See the file
  `license' for details on this and other legal matters.
*--------------------------------------------------------------*/


#include "cparsimcomm.h"

#ifndef __CMPICOMM_H__
#define __CMPICOMM_H__


class cMPICommunications : public cParsimCommunications
{
  protected:
    cCommBuffer *recycledBuffer;
    int numPartitions;
    int myRank;

  public:
    cMPICommunications();

    virtual ~cMPICommunications();

    virtual void init();

    virtual void shutdown();

    virtual int getNumPartitions();

    virtual int getProcId();

    virtual cCommBuffer *createCommBuffer();

    virtual void recycleCommBuffer(cCommBuffer *buffer);

    virtual void send(cCommBuffer *buffer, int tag, int destination);

    virtual void broadcast(cCommBuffer *buffer, int tag);

    virtual bool receiveBlocking(int filtTag, cCommBuffer *buffer, int& receivedTag, int& sourceProcId);

    virtual bool receiveNonblocking(int filtTag, cCommBuffer *buffer,  int& receivedTag, int& sourceProcId);
};

#endif

---