STAnalogMessageCreator.h

Go to the documentation of this file.

#ifndef STANALOGMESSAGECREATOR_H_
#define STANALOGMESSAGECREATOR_H_


#include "SingleThreadSimEngine.h"
#include "SingleThreadAnalogMsgDispatcher.h"
#include "AnalogDelayObjectMap.h"

class STAnalogMessageCreator
{
public:
    STAnalogMessageCreator(SingleThreadAnalogMsgDispatcher & analogMsgDispatcher,
                                                        SingleThreadSimEngine &simulationEngine, 
                                                        AnalogDelayObjectMap &delayObjectMap ,
                                                        delay_t minDelay);
    
    virtual ~STAnalogMessageCreator();


    template<typename srcType, typename destType>
    inline int addAnalogMessage(
        const SimObject::ID &sender,
        srcType senderPortOrField,
        const SimObject::ID &receiver,
        destType recvPortOrField, delay_t delay);

protected:
        SingleThreadAnalogMsgDispatcher & dispatcher;
        
        SingleThreadSimEngine & simEngine;
        
        AnalogDelayObjectMap & delay_objects_map;
        
        delay_t min_delay;

};

template<typename srcType, typename destType>
inline int STAnalogMessageCreator::addAnalogMessage(
    const SimObject::ID &sender,
    srcType senderPortOrField,
    const SimObject::ID &receiver,
    destType recvPortOrField, delay_t delay)
{
    if (delay == 0) {
        dispatcher.addAnalogMessage( simEngine.getObject( sender ),
                                               senderPortOrField, simEngine.getObject( receiver ), recvPortOrField);
    } else {
        SimObject *src_obj = dynamic_cast<SimObject*> (simEngine.getObject( sender ) );
        AnalogDelayObject *delay_object;
        if ((delay_object = delay_objects_map.find(src_obj, senderPortOrField)) == NULL) {
            AnalogDelayObject delay_object_model(min_delay);
            SimObject::ID id;
            simEngine.addObject( delay_object_model, id );
            delay_object = (AnalogDelayObject *)simEngine.getObject( id );
            delay_objects_map.insert(src_obj, senderPortOrField, delay_object );
        }
        delay_object->announceDelayedRead(delay);

        // Connect sender and delayer
        dispatcher.addAnalogMessage(src_obj, senderPortOrField, delay_object, 0);
        // connect delayer with receiver
        dispatcher.addAnalogMessage(delay_object, delay, simEngine.getObject( receiver ), recvPortOrField );
    }
    return 0;
}

#endif /*STANALOGMESSAGECREATOR_H_*/

---