MTIncomingAnalogMessageDispatcher.cpp

Go to the documentation of this file.

#include "MTIncomingAnalogMessageDispatcher.h"

using std::make_pair;

MTIncomingAnalogMessageDispatcher::MTIncomingAnalogMessageDispatcher()
{
    initialized = false;
    port_sources_positions = new sources_positions_type;
    field_sources_positions = new sources_positions_type;
}

MTIncomingAnalogMessageDispatcher::~MTIncomingAnalogMessageDispatcher()
{
    if (!initialized) {
        delete port_sources_positions;
        delete field_sources_positions;
    }
}


void MTIncomingAnalogMessageDispatcher::addAnalogMessage(AnalogDelayObject *src, analog_port_id_t src_port, SimObject *dest, analog_port_id_t dest_port)
{
    sources_positions_type::const_iterator pos_it;
    pair< AnalogDelayObject *, analog_port_id_t> src_pair(src, src_port);
    int position;
    if ((pos_it = port_sources_positions->find(src_pair)) != port_sources_positions->end() ) {
        position = pos_it->second;
    } else {
        position = port_msg_sources.size();
        port_sources_positions->insert(make_pair(src_pair, position));
        port_msg_destinations.push_back(vector< pair<SimObject *,analog_port_id_t> >());
        port_msg_sources.push_back(src_pair);
    }
    port_msg_destinations[position].push_back(make_pair(dest,dest_port));
}


void MTIncomingAnalogMessageDispatcher::addAnalogMessage(AnalogDelayObject *src, analog_port_id_t src_port, SimObject *dest, string destfield)
{
        const Field * dest_field = dest->findField(destfield);
    sources_positions_type::const_iterator pos_it;
    pair< AnalogDelayObject *, analog_port_id_t> src_pair(src, src_port);
    int position;
    if ((pos_it = field_sources_positions->find(src_pair)) != field_sources_positions->end() ) {
        position = pos_it->second;
    } else {
        position = field_msg_sources.size();
        field_sources_positions->insert(make_pair(src_pair, position));
        field_msg_destinations.push_back(vector< pair< void *, Field::ValueType > >());
        field_msg_sources.push_back(src_pair);
    }
    field_msg_destinations[position].push_back(make_pair(dest_field->getPtr(dest),dest_field->getType()));
}

void MTIncomingAnalogMessageDispatcher::dispatchIncomingAnalogMsgs(int step)
{
    // dispatch port messages
    msg_sources_type::const_iterator port_src_it;
    port_msg_destinations_type::const_iterator port_dest_it = port_msg_destinations.begin();
    for (port_src_it = port_msg_sources.begin() ; port_src_it != port_msg_sources.end() ; ++port_src_it, ++port_dest_it) {
        vector< pair<SimObject *, analog_port_id_t > >::const_iterator port_dest_it_2;
        for (port_dest_it_2 = port_dest_it->begin(); port_dest_it_2 != port_dest_it->end() ; ++port_dest_it_2) {
//              cerr << " new cycled dispatch value = " << port_src_it->first->getCycledAnalogOutput(port_src_it->second - step) << endl;
                    port_dest_it_2->first->setAnalogInput(
                        port_src_it->first->getCycledAnalogOutput(port_src_it->second - step), port_dest_it_2->second);
        }
    }

    //  dispatch field messages
    msg_sources_type::const_iterator field_src_it;
    field_msg_destinations_type::iterator field_dest_it = field_msg_destinations.begin();
    for (field_src_it = field_msg_sources.begin(); field_src_it != field_msg_sources.end(); ++field_src_it, ++field_dest_it) {
        vector< pair< void *, Field::ValueType > >::iterator field_dest_it_2;
        for (field_dest_it_2 = field_dest_it->begin() ; field_dest_it_2 != field_dest_it->end(); ++field_dest_it_2)
            Field::setValue(field_dest_it_2->first, field_dest_it_2->second, field_src_it->first->getCycledAnalogOutput(field_src_it->second - step) );
    }
}


void MTIncomingAnalogMessageDispatcher::initialize()
{
    if (!initialized) {
        initialized = true;
        delete port_sources_positions;
        delete field_sources_positions;
    }
}

---