#include <DistributedOutgoingAnalogMsgDispatcher.h>
Public Member Functions | |
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 Types | |
typedef vector< pair < SimObject *, analog_port_id_t > > | port_outgoing_analog_msgs_type |
typedef vector< pair< void *, Field::ValueType > > | field_outgoing_analog_msgs_type |
Protected Attributes | |
engineid_t | engineID |
int | nNodes |
delay_t | minDelay |
double * | mpiBuffer |
port_outgoing_analog_msgs_type | port_msgs |
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 |
Definition at line 18 of file DistributedOutgoingAnalogMsgDispatcher.h.
typedef vector< pair<SimObject*, analog_port_id_t> > DistributedOutgoingAnalogMsgDispatcher::port_outgoing_analog_msgs_type [protected] |
Definition at line 45 of file DistributedOutgoingAnalogMsgDispatcher.h.
typedef vector< pair<void *, Field::ValueType> > DistributedOutgoingAnalogMsgDispatcher::field_outgoing_analog_msgs_type [protected] |
Definition at line 48 of file DistributedOutgoingAnalogMsgDispatcher.h.
DistributedOutgoingAnalogMsgDispatcher::DistributedOutgoingAnalogMsgDispatcher | ( | engineid_t | eng_id, | |
delay_t | minimumDelay, | |||
MPIOutputBuffer * | mpiOutputBuffer | |||
) |
Definition at line 3 of file DistributedOutgoingAnalogMsgDispatcher.cpp.
References initialized, and outgoingSources.
DistributedOutgoingAnalogMsgDispatcher::~DistributedOutgoingAnalogMsgDispatcher | ( | ) | [virtual] |
Definition at line 10 of file DistributedOutgoingAnalogMsgDispatcher.cpp.
References initialized, and outgoingSources.
void DistributedOutgoingAnalogMsgDispatcher::addOutgoingAnalogMessage | ( | SimObject * | src, | |
analog_port_id_t | src_port | |||
) |
Definition at line 16 of file DistributedOutgoingAnalogMsgDispatcher.cpp.
References engineID, MPIOutputBuffer::getAnalogMsgCounter(), OutgoingAnalogMPIBufferSourcesSet::insert(), outgoingSources, outputBuffer, port_msgs, and port_msgs_buff_pos.
void DistributedOutgoingAnalogMsgDispatcher::addOutgoingAnalogMessage | ( | SimObject * | src, | |
string | srcfield | |||
) |
Definition at line 24 of file DistributedOutgoingAnalogMsgDispatcher.cpp.
References engineID, field_msgs, field_msgs_buff_pos, SimObject::findField(), MPIOutputBuffer::getAnalogMsgCounter(), Field::getPtr(), Field::getType(), OutgoingAnalogMPIBufferSourcesSet::insert(), outgoingSources, and outputBuffer.
void DistributedOutgoingAnalogMsgDispatcher::dispatchMPIOutgoingAnalogMsgs | ( | int | step | ) |
Definition at line 33 of file DistributedOutgoingAnalogMsgDispatcher.cpp.
References field_msgs, field_msgs_buff_pos, Field::getValue(), minDelay, mpiBuffer, port_msgs, and port_msgs_buff_pos.
void DistributedOutgoingAnalogMsgDispatcher::initialize | ( | ) |
Definition at line 57 of file DistributedOutgoingAnalogMsgDispatcher.cpp.
References engineID, MPIOutputBuffer::getAnalogBuffer(), MPIOutputBuffer::getAnalogMsgCounter(), initialized, minDelay, mpiBuffer, outgoingSources, and outputBuffer.
Definition at line 35 of file DistributedOutgoingAnalogMsgDispatcher.h.
Referenced by addOutgoingAnalogMessage(), and initialize().
int DistributedOutgoingAnalogMsgDispatcher::nNodes [protected] |
Definition at line 37 of file DistributedOutgoingAnalogMsgDispatcher.h.
Definition at line 39 of file DistributedOutgoingAnalogMsgDispatcher.h.
Referenced by dispatchMPIOutgoingAnalogMsgs(), and initialize().
double* DistributedOutgoingAnalogMsgDispatcher::mpiBuffer [protected] |
Definition at line 41 of file DistributedOutgoingAnalogMsgDispatcher.h.
Referenced by dispatchMPIOutgoingAnalogMsgs(), and initialize().
Definition at line 46 of file DistributedOutgoingAnalogMsgDispatcher.h.
Referenced by addOutgoingAnalogMessage(), and dispatchMPIOutgoingAnalogMsgs().
Definition at line 49 of file DistributedOutgoingAnalogMsgDispatcher.h.
Referenced by addOutgoingAnalogMessage(), and dispatchMPIOutgoingAnalogMsgs().
vector< unsigned > DistributedOutgoingAnalogMsgDispatcher::port_msgs_buff_pos [protected] |
Definition at line 51 of file DistributedOutgoingAnalogMsgDispatcher.h.
Referenced by addOutgoingAnalogMessage(), and dispatchMPIOutgoingAnalogMsgs().
vector< unsigned > DistributedOutgoingAnalogMsgDispatcher::field_msgs_buff_pos [protected] |
Definition at line 52 of file DistributedOutgoingAnalogMsgDispatcher.h.
Referenced by addOutgoingAnalogMessage(), and dispatchMPIOutgoingAnalogMsgs().
OutgoingAnalogMPIBufferSourcesSet* DistributedOutgoingAnalogMsgDispatcher::outgoingSources [protected] |
Definition at line 54 of file DistributedOutgoingAnalogMsgDispatcher.h.
Referenced by addOutgoingAnalogMessage(), DistributedOutgoingAnalogMsgDispatcher(), initialize(), and ~DistributedOutgoingAnalogMsgDispatcher().
Definition at line 56 of file DistributedOutgoingAnalogMsgDispatcher.h.
Referenced by addOutgoingAnalogMessage(), and initialize().
Definition at line 58 of file DistributedOutgoingAnalogMsgDispatcher.h.
Referenced by DistributedOutgoingAnalogMsgDispatcher(), initialize(), and ~DistributedOutgoingAnalogMsgDispatcher().