cparsimpartition.h

//=========================================================================
//  CPARSIMPARTITION.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_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;


class SIM_API cParsimPartition : public cObject, public cISimulationLifecycleListener
{
  protected:
    cSimulation *sim;
    cParsimCommunications *comm;
    cParsimSynchronizer *synch;
    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, int procId, int moduleId, int gateId, void *data);

    virtual void processReceivedBuffer(cCommBuffer *buffer, int tag, int sourceProcId);

    virtual void processReceivedMessage(cMessage *msg, int destModuleId, int destGateId, int sourceProcId);

    virtual void broadcastTerminationException(cTerminationException& e);

    virtual void broadcastException(std::exception& e);
};

}  // namespace omnetpp


#endif