cfilecomm.h

//=========================================================================
//  CFILECOMM.H - part of
//
//                  OMNeT++/OMNEST
//           Discrete System Simulation in C++
//
//  Author: Andras Varga, 2003
//          Dept. of Electrical and Computer Systems Engineering,
//          Monash University, Melbourne, Australia
//
//=========================================================================

/*--------------------------------------------------------------*
  Copyright (C) 2003-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.
*--------------------------------------------------------------*/

#ifndef __OMNETPP_CFILECOMM_H
#define __OMNETPP_CFILECOMM_H

#include "omnetpp/cparsimcomm.h"
#include "omnetpp/simutil.h"

namespace omnetpp {


class SIM_API cFileCommunications : public cParsimCommunications
{
  protected:
    int numPartitions;
    int myProcId;

    int seqNum;
    opp_string commDirPrefix;
    opp_string readDirPrefix;
    bool preserveReadFiles;

  public:
    cFileCommunications();

    virtual ~cFileCommunications();

    virtual void init() 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 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