DistributedAnalogMessageDispatcher.h

Go to the documentation of this file.

#ifndef DISTRIBUTEDANALOGMESSAGEDISPATCHER_H_
#define DISTRIBUTEDANALOGMESSAGEDISPATCHER_H_

#include "AnalogMessageDispatcher.h"
#include "DistributedIncomingAnalogMsgDispatcher.h"
#include "DistributedOutgoingAnalogMsgDispatcher.h"
#include "MTIncomingAnalogMessageDispatcher.h"
#include "DistributedCycledAnalogMsgDispatcher.h"



class DistributedAnalogMessageDispatcher : public AnalogMessageDispatcher, public DistributedCycledAnalogMsgDispatcher 
{
public:
    DistributedAnalogMessageDispatcher(int numNodes,
                                       int minimumDelay,
                                       vector< DistributedIncomingAnalogMsgDispatcher* > & incomingDispatchers,
                                       vector< DistributedOutgoingAnalogMsgDispatcher* > & outgoingDispatchers,
                                       AnalogMessageDispatcher &localDispatcher);

    virtual ~DistributedAnalogMessageDispatcher();

    void dispatchOutgoingAnalogMsgs();

    void dispatchIncomingAnalogMsgs(int step);

    // of a simulation cycle ( = minDelay steps )
    virtual void dispatchDelayerCycledIncomingAnalogMsgs();

    virtual void dispatchAnalogMsgs();

    virtual void initialize();
    virtual void reset(double dt);

    vector<DistributedIncomingAnalogMsgDispatcher*> & incoming()
    {
        return incoming_dispatchers;
    }

    vector<DistributedOutgoingAnalogMsgDispatcher*> & outgoing()
    {
        return outgoing_dispatchers;
    }


    MTIncomingAnalogMessageDispatcher & cycledLocal()
    {
        return cycledLocalDispatcher;   
    }

protected:

    int nNodes;

    int minDelay;

    vector< DistributedIncomingAnalogMsgDispatcher* > &incoming_dispatchers;
    vector< DistributedOutgoingAnalogMsgDispatcher* > &outgoing_dispatchers;


    MTIncomingAnalogMessageDispatcher cycledLocalDispatcher;

    AnalogMessageDispatcher &local_dispatcher;

    int currentStep;
};

#endif /*DISTRIBUTEDANALOGMESSAGEDISPATCHER_H_*/

---