DistributedAnalogMessageCreator.h

Go to the documentation of this file.

#ifndef DISTRIBUTEDANALOGMESSAGECREATOR_H_
#define DISTRIBUTEDANALOGMESSAGECREATOR_H_

#include "SimObject.h"
#include "SingleThreadSimEngine.h"
#include "AnalogDelayObject.h"
#include "DistributedAnalogMessageDispatcher.h"


class DistributedAnalogMessageCreator
{
public:
        DistributedAnalogMessageCreator(
                SingleThreadSimEngine & singleThreadEngine,
                DistributedAnalogMessageDispatcher &distAnalogMsgDispatcher,
                delay_t minAnalogDelay) :
                dispatcher(distAnalogMsgDispatcher),
                stEngine(singleThreadEngine),
                min_analog_delay(minAnalogDelay)
        {};
                          
        virtual ~DistributedAnalogMessageCreator();
        
        template <class AnalogSrcType>
        inline void addOutgoingAnalogMessage(const SimObject::ID &src, AnalogSrcType srcFieldOrPort, nodeid_t dest_node);
        
        template <class AnalogSrcType, class AnalogDestType>
        inline void addIncomingAnalogMessage(const SimObject::ID &src, AnalogSrcType srcFieldOrPort, 
                                                                             const SimObject::ID &receiver, AnalogDestType destFieldOrPort, delay_t delay);     

protected:
        DistributedAnalogMessageDispatcher & dispatcher;
        SingleThreadSimEngine &stEngine;
        delay_t min_analog_delay;
};

template <class AnalogSrcType>
inline void DistributedAnalogMessageCreator::addOutgoingAnalogMessage(const SimObject::ID &src, AnalogSrcType srcFieldOrPort, nodeid_t dest_node)
{
        dispatcher.outgoing()[dest_node]->addOutgoingAnalogMessage((SimObject *)stEngine.getObject(src), srcFieldOrPort);
}

template <class AnalogSrcType, class AnalogDestType>
inline void DistributedAnalogMessageCreator::addIncomingAnalogMessage(const SimObject::ID &src, AnalogSrcType srcFieldOrPort, const SimObject::ID &receiver, AnalogDestType destFieldOrPort, delay_t delay)
{
        // connect mpi buffer position with associated delayer
        IncomingAnalogDelayObject * delayObj = dispatcher.incoming()[src.node]->addDelayerCycledIncomingAnalogMessage(src, srcFieldOrPort);
        delayObj->announceDelayedRead(delay);
    // connect delayer with receiver
    dispatcher.cycledLocal().addAnalogMessage(delayObj, delay - 1, (SimObject *)stEngine.getObject(receiver), destFieldOrPort); 
}


#endif /*DISTRIBUTEDANALOGMESSAGECREATOR_H_*/

---