DistributedOutgoingAnalogMsgDispatcher.cpp

Go to the documentation of this file.

#include "DistributedOutgoingAnalogMsgDispatcher.h"

DistributedOutgoingAnalogMsgDispatcher::DistributedOutgoingAnalogMsgDispatcher(engineid_t eng_id, delay_t minimumDelay, MPIOutputBuffer *mpiOutputBuffer)
        : engineID(eng_id), minDelay(minimumDelay), outputBuffer(mpiOutputBuffer)
{
    initialized = false;
    outgoingSources = new OutgoingAnalogMPIBufferSourcesSet();
}

DistributedOutgoingAnalogMsgDispatcher::~DistributedOutgoingAnalogMsgDispatcher()
{
        if (!initialized)
                delete outgoingSources;
}

void DistributedOutgoingAnalogMsgDispatcher::addOutgoingAnalogMessage(SimObject *src, analog_port_id_t src_port)
{
    if (outgoingSources->insert(src, src_port)) {
        port_msgs_buff_pos.push_back(outputBuffer->getAnalogMsgCounter(engineID)++);
        port_msgs.push_back(make_pair(src, src_port));
    }
}

void DistributedOutgoingAnalogMsgDispatcher::addOutgoingAnalogMessage(SimObject *src, string srcfield)
{
        const Field * src_field = src->findField(srcfield);
    if (outgoingSources->insert(src, srcfield)) {
        field_msgs_buff_pos.push_back(outputBuffer->getAnalogMsgCounter(engineID)++);
        field_msgs.push_back( make_pair(src_field->getPtr(src), src_field->getType()));
    }
}

void DistributedOutgoingAnalogMsgDispatcher::dispatchMPIOutgoingAnalogMsgs(int step)
{
        // dispatch port messages
        port_outgoing_analog_msgs_type::iterator port_msgs_it;
        vector< unsigned >::const_iterator port_msgs_buff_pos_iter = port_msgs_buff_pos.begin();
        for (port_msgs_it = port_msgs.begin(); port_msgs_it != port_msgs.end(); ++port_msgs_it)
        {
                /*cerr << "Dispatching new value = " << port_msgs_it->first->getAnalogOutput(port_msgs_it->second) << endl;
                cerr << " address = " << (mpiBuffer + minDelay * (*(port_msgs_buff_pos_iter++)) + step) << endl;
                cerr << " buffer = " << mpiBuffer << " port_msgs_buff_pos_iter = " << *(port_msgs_buff_pos_iter) << " step=" << step << endl;*/
                *(mpiBuffer + minDelay * (*(port_msgs_buff_pos_iter++)) + step) =
                                        port_msgs_it->first->getAnalogOutput(port_msgs_it->second);
        }


    // dispatch field messages
        field_outgoing_analog_msgs_type::iterator field_msgs_it;
        vector< unsigned >::const_iterator field_msgs_buff_pos_iter = field_msgs_buff_pos.begin();
        for (field_msgs_it = field_msgs.begin(); field_msgs_it != field_msgs.end(); ++field_msgs_it) {
                *(mpiBuffer + minDelay * (*(field_msgs_buff_pos_iter++)) + step) = Field::getValue(field_msgs_it->first, field_msgs_it->second);
        }

}

void DistributedOutgoingAnalogMsgDispatcher::initialize()
{
        mpiBuffer = outputBuffer->getAnalogBuffer() + minDelay * (engineID ? outputBuffer->getAnalogMsgCounter(engineID - 1) : 0);
        if (!initialized) {
        initialized = true;
        delete outgoingSources;
        }
}

---