DistributedOutgoingAnalogMsgDispatcher.h

Go to the documentation of this file.

#ifndef DISTRIBUTEDOUTGOINGANALOGMSGDISPATCHER_H_
#define DISTRIBUTEDOUTGOINGANALOGMSGDISPATCHER_H_

#include <vector>
#include <string>
#include <utility>

#include "SimObject.h"
#include "OutgoingAnalogMPIBufferSourcesSet.h"
#include "MPIOutputBuffer.h"

using std::vector;
using std::string;
using std::pair;
using std::make_pair;


class DistributedOutgoingAnalogMsgDispatcher
{
public:

    DistributedOutgoingAnalogMsgDispatcher(engineid_t eng_id, delay_t minimumDelay, MPIOutputBuffer *mpiOutputBuffer);
    
    virtual ~DistributedOutgoingAnalogMsgDispatcher();

    void addOutgoingAnalogMessage(SimObject *src, analog_port_id_t src_port);

    void addOutgoingAnalogMessage(SimObject *src, string srcfield);

    void dispatchMPIOutgoingAnalogMsgs(int step);

    void initialize();

protected:
        engineid_t engineID;

    int nNodes;

    delay_t minDelay;

    double *mpiBuffer;

    //**********************************************************************
    // lists of source -> destination pairs defining all analog messages
    typedef vector< pair<SimObject*, analog_port_id_t> > port_outgoing_analog_msgs_type;
    port_outgoing_analog_msgs_type port_msgs;

    typedef vector< pair<void *, Field::ValueType> > field_outgoing_analog_msgs_type;
    field_outgoing_analog_msgs_type field_msgs;

    vector< unsigned > port_msgs_buff_pos;
    vector< unsigned > field_msgs_buff_pos;

    OutgoingAnalogMPIBufferSourcesSet *outgoingSources;

    MPIOutputBuffer *outputBuffer;

    bool initialized;

};

#endif /*DISTRIBUTEDOUTGOINGANALOGMSGDISPATCHER_H_*/

---