#include <DistributedIncomingAnalogMsgDispatcher.h>
Public Member Functions | |
DistributedIncomingAnalogMsgDispatcher (delay_t minimumDelay, MPIInputBuffer *mpiInputBuffer, DistIncomingAnalogSources2BufPosMap *bufferPositionsOfIncomingSources) | |
virtual | ~DistributedIncomingAnalogMsgDispatcher () |
void | dispatchDelayerCycledIncomingAnalogMsgs () |
void | initialize () |
void | reset (double dt) |
template<typename AnalogSrcType> | |
IncomingAnalogDelayObject * | addDelayerCycledIncomingAnalogMessage (const SimObject::ID &src, AnalogSrcType srcFieldOrPort) |
Protected Attributes | |
int | nNodes |
delay_t | minDelay |
vector< unsigned > | cycled_inc_msgs_src_buff_pos |
vector< engineid_t > * | cycled_buf_pos_source_eng_ids |
vector < IncomingAnalogDelayObject * > | cycled_inc_msgs_delayer_destinations |
DistIncomingAnalogSources2BufPosMap * | bufPosOfIncomingSources |
MPIInputBuffer * | inputBuffer |
double * | mpiBufferPtr |
bool | initialized |
Definition at line 19 of file DistributedIncomingAnalogMsgDispatcher.h.
DistributedIncomingAnalogMsgDispatcher::DistributedIncomingAnalogMsgDispatcher | ( | delay_t | minimumDelay, | |
MPIInputBuffer * | mpiInputBuffer, | |||
DistIncomingAnalogSources2BufPosMap * | bufferPositionsOfIncomingSources | |||
) |
Definition at line 7 of file DistributedIncomingAnalogMsgDispatcher.cpp.
References cycled_buf_pos_source_eng_ids, and initialized.
DistributedIncomingAnalogMsgDispatcher::~DistributedIncomingAnalogMsgDispatcher | ( | ) | [virtual] |
Definition at line 20 of file DistributedIncomingAnalogMsgDispatcher.cpp.
References cycled_buf_pos_source_eng_ids, cycled_inc_msgs_delayer_destinations, and initialized.
void DistributedIncomingAnalogMsgDispatcher::dispatchDelayerCycledIncomingAnalogMsgs | ( | ) |
Definition at line 65 of file DistributedIncomingAnalogMsgDispatcher.cpp.
References cycled_inc_msgs_delayer_destinations, cycled_inc_msgs_src_buff_pos, minDelay, and mpiBufferPtr.
void DistributedIncomingAnalogMsgDispatcher::initialize | ( | ) |
Definition at line 78 of file DistributedIncomingAnalogMsgDispatcher.cpp.
References cycled_buf_pos_source_eng_ids, cycled_inc_msgs_delayer_destinations, cycled_inc_msgs_src_buff_pos, MPIInputBuffer::getAnalogBuffer(), MPIInputBuffer::getAnalogMsgCounter(), initialized, inputBuffer, and mpiBufferPtr.
void DistributedIncomingAnalogMsgDispatcher::reset | ( | double | dt | ) |
Definition at line 109 of file DistributedIncomingAnalogMsgDispatcher.cpp.
References cycled_inc_msgs_delayer_destinations.
IncomingAnalogDelayObject * DistributedIncomingAnalogMsgDispatcher::addDelayerCycledIncomingAnalogMessage | ( | const SimObject::ID & | src, | |
AnalogSrcType | srcFieldOrPort | |||
) | [inline] |
Definition at line 91 of file DistributedIncomingAnalogMsgDispatcher.h.
References bufPosOfIncomingSources, cycled_buf_pos_source_eng_ids, cycled_inc_msgs_delayer_destinations, cycled_inc_msgs_src_buff_pos, DistIncomingAnalogSources2BufPosMap::end(), SimObject::ID::eng, DistIncomingAnalogSources2BufPosMap::find(), MPIInputBuffer::getAnalogMsgCounter(), inputBuffer, DistIncomingAnalogSources2BufPosMap::insert(), and minDelay.
int DistributedIncomingAnalogMsgDispatcher::nNodes [protected] |
Definition at line 48 of file DistributedIncomingAnalogMsgDispatcher.h.
Definition at line 50 of file DistributedIncomingAnalogMsgDispatcher.h.
Referenced by addDelayerCycledIncomingAnalogMessage(), and dispatchDelayerCycledIncomingAnalogMsgs().
vector< unsigned > DistributedIncomingAnalogMsgDispatcher::cycled_inc_msgs_src_buff_pos [protected] |
Definition at line 67 of file DistributedIncomingAnalogMsgDispatcher.h.
Referenced by addDelayerCycledIncomingAnalogMessage(), dispatchDelayerCycledIncomingAnalogMsgs(), and initialize().
vector< engineid_t >* DistributedIncomingAnalogMsgDispatcher::cycled_buf_pos_source_eng_ids [protected] |
Definition at line 69 of file DistributedIncomingAnalogMsgDispatcher.h.
Referenced by addDelayerCycledIncomingAnalogMessage(), DistributedIncomingAnalogMsgDispatcher(), initialize(), and ~DistributedIncomingAnalogMsgDispatcher().
vector< IncomingAnalogDelayObject *> DistributedIncomingAnalogMsgDispatcher::cycled_inc_msgs_delayer_destinations [protected] |
Definition at line 71 of file DistributedIncomingAnalogMsgDispatcher.h.
Referenced by addDelayerCycledIncomingAnalogMessage(), dispatchDelayerCycledIncomingAnalogMsgs(), initialize(), reset(), and ~DistributedIncomingAnalogMsgDispatcher().
DistIncomingAnalogSources2BufPosMap* DistributedIncomingAnalogMsgDispatcher::bufPosOfIncomingSources [protected] |
Definition at line 80 of file DistributedIncomingAnalogMsgDispatcher.h.
Referenced by addDelayerCycledIncomingAnalogMessage().
Definition at line 82 of file DistributedIncomingAnalogMsgDispatcher.h.
Referenced by addDelayerCycledIncomingAnalogMessage(), and initialize().
Definition at line 84 of file DistributedIncomingAnalogMsgDispatcher.h.
Referenced by dispatchDelayerCycledIncomingAnalogMsgs(), and initialize().
Definition at line 86 of file DistributedIncomingAnalogMsgDispatcher.h.
Referenced by DistributedIncomingAnalogMsgDispatcher(), initialize(), and ~DistributedIncomingAnalogMsgDispatcher().