cparsimpartition.h Source File¶

Parallel Simulation API: cparsimpartition.h Source File
Parallel Simulation API
//=========================================================================
//  CPARSIMPARTITION.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_CPARSIMPARTITION_H
#define __OMNETPP_CPARSIMPARTITION_H
 
#include "omnetpp/simkerneldefs.h"
#include "omnetpp/cobject.h"
#include "omnetpp/simtime_t.h"
#include "omnetpp/clifecyclelistener.h"
 
namespace omnetpp {
 
class cSimulation;
class cParsimSynchronizer;
class cParsimCommunications;
class cCommBuffer;
class cException;
class cTerminationException;
struct SendOptions;
class SIM_API cParsimPartition : public cObject, public cISimulationLifecycleListener
{
  protected:
    cSimulation *sim = nullptr;
    cParsimCommunications *comm = nullptr;
    cParsimSynchronizer *synch = nullptr;
    bool debug;
 
  protected:
    // internal: fills in remote gate addresses of all cProxyGate's in the current partition
    void connectRemoteGates();
    virtual void lifecycleEvent(SimulationLifecycleEventType eventType, cObject *details) override;
 
  public:
    cParsimPartition();
    virtual ~cParsimPartition() {}
    void setContext(cSimulation *sim, cParsimCommunications *comm, cParsimSynchronizer *synch);
    void startRun();
    void endRun();
    void shutdown();
    virtual void processOutgoingMessage(cMessage *msg, const SendOptions& options, int procId, int moduleId, int gateId, void *data);
    virtual void processReceivedBuffer(cCommBuffer *buffer, int tag, int sourceProcId);
    virtual void processReceivedMessage(cMessage *msg, const SendOptions& options, int destModuleId, int destGateId, int sourceProcId);
    virtual void broadcastTerminationException(cTerminationException& e);
    virtual void broadcastException(std::exception& e);
};
 
}  // namespace omnetpp
 
 
#endif
 