MTAnalogMessageCreator.h

Go to the documentation of this file.

#ifndef MTANALOGMESSAGECREATOR_H_
#define MTANALOGMESSAGECREATOR_H_

#include "MultiThreadAnalogMsgDispatcher.h"
#include "MultiThreadSimEngine.h"
#include "AnalogDelayObjectMap.h"

class MTAnalogMessageCreator
{
public:
    MTAnalogMessageCreator(vector<MultiThreadAnalogMsgDispatcher*> & mtAnalogMsgDispatchers,
                           MultiThreadSimEngine &mtSimEngine,
                           AnalogDelayObjectMap &analogDelayObjectsMap,
                           delay_t minDelay) :
            dispatchers(mtAnalogMsgDispatchers),
            simEngine(mtSimEngine),
            analog_delay_objects_map(analogDelayObjectsMap),
            min_delay(minDelay)
    {};
    virtual ~MTAnalogMessageCreator();

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


protected:
    vector< MultiThreadAnalogMsgDispatcher*> &dispatchers;

    MultiThreadSimEngine &simEngine;

    AnalogDelayObjectMap & analog_delay_objects_map;

    delay_t min_delay;
};


template<typename srcType, typename destType>
inline int MTAnalogMessageCreator::addAnalogMessage(
    const SimObject::ID &sender,
    srcType senderPortOrField,
    const SimObject::ID &receiver,
    destType recvPortOrField,
    delay_t delay )
{
    if (delay == 0) {
        dispatchers[receiver.eng]->mTImmediateDispatcher().addAnalogMessage( simEngine.getObject(sender), senderPortOrField,
                simEngine.getObject(receiver), recvPortOrField);
    } else {
        SimObject *sender_ptr = dynamic_cast<SimObject*> (simEngine.getObject(sender));
        AnalogDelayObject *delay_object;
        SimObject::ID delayer_id = sender;
        if ((delay_object = analog_delay_objects_map.find(sender_ptr, senderPortOrField)) == NULL) {
            AnalogDelayObject delay_object_model(min_delay);
            simEngine.addObject(delay_object_model, delayer_id);
            delay_object = (AnalogDelayObject *)simEngine.getObject( delayer_id );
            delayer_id.type = delay_object->getObjectTypeID();
            analog_delay_objects_map.insert(sender_ptr, senderPortOrField, delay_object);
            // Connect sender and delayer
            dispatchers[sender.eng]->sTLocalDispatcher().addAnalogMessage(sender_ptr, senderPortOrField, delay_object, 0);
        }
        if (!delay_object->isScheduledForAdvanceCycle())
            simEngine.addForAdvanceCycle(delay_object, delayer_id);
        delay_object->announceDelayedRead(delay);

        // connect delayer with receiver
        dispatchers[receiver.eng]->mTDelayedDispatcher().addAnalogMessage(delay_object, delay-1, simEngine.getObject(receiver), recvPortOrField);
    }

    return 0;
}

#endif /*MTANALOGMESSAGECREATOR_H_*/

---