cidealsimulationprot.h Source File¶

Parallel Simulation API: cidealsimulationprot.h Source File
Parallel Simulation API
//=========================================================================
//  CIDEALSIMULATIONPROT.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.
*--------------------------------------------------------------*/
 
#ifndef __OMNETPP_CIDEALSIMULATIONPROT_H
#define __OMNETPP_CIDEALSIMULATIONPROT_H
 
#include "cparsimprotocolbase.h"
 
namespace omnetpp {
 
class cCommBuffer;
class SIM_API cIdealSimulationProtocol : public cParsimProtocolBase
{
  public:
    // stores one external event, as needed for the ISP algorithm
    struct ExternalEvent {
        simtime_t t;    // time of event
        int srcProcId;  // origin of event
    };
 
  protected:
    bool debug;
    FILE *fin = nullptr;  // the event log file
    ExternalEvent nextExternalEvent; // holds the next event
 
    // preloaded table of event times
    ExternalEvent *table; // array to hold values
    int tableSize;        // allocated size of table
    int numItems = 0;     // num in items in table (numItems<tableSize possible)
    int nextPos = 0;      // position of 1st unused item in table
 
  protected:
    // process cMessages received from other partitions; see same method in2
    // cISPEventLogger for more explanation
    virtual void processReceivedMessage(cMessage *msg, const SendOptions& options, int destModuleId, int destGateId, int sourceProcId) override;
 
    // read an event from event log file
    virtual void readNextRecordedEvent();
 
  public:
    cIdealSimulationProtocol();
    virtual ~cIdealSimulationProtocol();
    virtual void startRun() override;
    virtual void endRun() override;
    virtual cEvent *takeNextEvent() override;
    virtual void putBackEvent(cEvent *event) override;
};
 
}  // namespace omnetpp
 
 
#endif
 