#include <DistributedAnalogMessageDispatcher.h>
Definition at line 12 of file DistributedAnalogMessageDispatcher.h.
DistributedAnalogMessageDispatcher::DistributedAnalogMessageDispatcher | ( | int | numNodes, | |
int | minimumDelay, | |||
vector< DistributedIncomingAnalogMsgDispatcher * > & | incomingDispatchers, | |||
vector< DistributedOutgoingAnalogMsgDispatcher * > & | outgoingDispatchers, | |||
AnalogMessageDispatcher & | localDispatcher | |||
) |
Definition at line 3 of file DistributedAnalogMessageDispatcher.cpp.
DistributedAnalogMessageDispatcher::~DistributedAnalogMessageDispatcher | ( | ) | [virtual] |
Definition at line 14 of file DistributedAnalogMessageDispatcher.cpp.
void DistributedAnalogMessageDispatcher::dispatchOutgoingAnalogMsgs | ( | ) |
Used in distributed engine or interleaved outgoing dispatching -> mpi exchange -> incoming dispatching.
Definition at line 18 of file DistributedAnalogMessageDispatcher.cpp.
References currentStep, and outgoing_dispatchers.
Referenced by dispatchAnalogMsgs().
void DistributedAnalogMessageDispatcher::dispatchIncomingAnalogMsgs | ( | int | step | ) |
Definition at line 26 of file DistributedAnalogMessageDispatcher.cpp.
void DistributedAnalogMessageDispatcher::dispatchDelayerCycledIncomingAnalogMsgs | ( | ) | [virtual] |
Used to update new mpi incoming values to analog delayer objects at the beginning.
Implements DistributedCycledAnalogMsgDispatcher.
Definition at line 33 of file DistributedAnalogMessageDispatcher.cpp.
References currentStep, and incoming_dispatchers.
void DistributedAnalogMessageDispatcher::dispatchAnalogMsgs | ( | ) | [virtual] |
Invoked in the single thread engine for a distributed scenario.
Implements AnalogMessageDispatcher.
Definition at line 43 of file DistributedAnalogMessageDispatcher.cpp.
References currentStep, cycledLocalDispatcher, AnalogMessageDispatcher::dispatchAnalogMsgs(), MTIncomingAnalogMessageDispatcher::dispatchIncomingAnalogMsgs(), dispatchOutgoingAnalogMsgs(), and local_dispatcher.
void DistributedAnalogMessageDispatcher::initialize | ( | ) | [virtual] |
Implements AnalogMessageDispatcher.
Definition at line 52 of file DistributedAnalogMessageDispatcher.cpp.
References cycledLocalDispatcher, incoming_dispatchers, MTIncomingAnalogMessageDispatcher::initialize(), and outgoing_dispatchers.
Referenced by DistributedSingleThreadNetwork::_initialize_().
void DistributedAnalogMessageDispatcher::reset | ( | double | dt | ) | [virtual] |
Implements AnalogMessageDispatcher.
Definition at line 65 of file DistributedAnalogMessageDispatcher.cpp.
References currentStep, incoming_dispatchers, local_dispatcher, and AnalogMessageDispatcher::reset().
Referenced by DistributedSingleThreadNetwork::_reset_().
vector<DistributedIncomingAnalogMsgDispatcher*>& DistributedAnalogMessageDispatcher::incoming | ( | ) | [inline] |
Definition at line 38 of file DistributedAnalogMessageDispatcher.h.
References incoming_dispatchers.
Referenced by DistributedAnalogMessageCreator::addIncomingAnalogMessage().
vector<DistributedOutgoingAnalogMsgDispatcher*>& DistributedAnalogMessageDispatcher::outgoing | ( | ) | [inline] |
Definition at line 43 of file DistributedAnalogMessageDispatcher.h.
References outgoing_dispatchers.
Referenced by DistributedAnalogMessageCreator::addOutgoingAnalogMessage().
MTIncomingAnalogMessageDispatcher& DistributedAnalogMessageDispatcher::cycledLocal | ( | ) | [inline] |
Definition at line 49 of file DistributedAnalogMessageDispatcher.h.
References cycledLocalDispatcher.
Referenced by DistributedAnalogMessageCreator::addIncomingAnalogMessage().
int DistributedAnalogMessageDispatcher::nNodes [protected] |
Definition at line 56 of file DistributedAnalogMessageDispatcher.h.
int DistributedAnalogMessageDispatcher::minDelay [protected] |
Definition at line 58 of file DistributedAnalogMessageDispatcher.h.
vector< DistributedIncomingAnalogMsgDispatcher* >& DistributedAnalogMessageDispatcher::incoming_dispatchers [protected] |
Definition at line 60 of file DistributedAnalogMessageDispatcher.h.
Referenced by dispatchDelayerCycledIncomingAnalogMsgs(), incoming(), initialize(), and reset().
vector< DistributedOutgoingAnalogMsgDispatcher* >& DistributedAnalogMessageDispatcher::outgoing_dispatchers [protected] |
Definition at line 61 of file DistributedAnalogMessageDispatcher.h.
Referenced by dispatchOutgoingAnalogMsgs(), initialize(), and outgoing().
MTIncomingAnalogMessageDispatcher DistributedAnalogMessageDispatcher::cycledLocalDispatcher [protected] |
Definition at line 64 of file DistributedAnalogMessageDispatcher.h.
Referenced by cycledLocal(), dispatchAnalogMsgs(), and initialize().
Definition at line 66 of file DistributedAnalogMessageDispatcher.h.
Referenced by dispatchAnalogMsgs(), and reset().
int DistributedAnalogMessageDispatcher::currentStep [protected] |
Definition at line 68 of file DistributedAnalogMessageDispatcher.h.
Referenced by dispatchAnalogMsgs(), dispatchDelayerCycledIncomingAnalogMsgs(), dispatchOutgoingAnalogMsgs(), and reset().