MultiThreadAnalogMsgDispatcher.cpp

Go to the documentation of this file.

#include "MultiThreadAnalogMsgDispatcher.h"

MultiThreadAnalogMsgDispatcher::~MultiThreadAnalogMsgDispatcher()
{}

void MultiThreadAnalogMsgDispatcher::dispatchAnalogMsgs()
{
        if (min_delay == 0) {
                mt_incoming_immediate_analog_msgs_dispatcher.dispatchAnalogMsgs();
                thr_barrier->wait();
        }

        mt_incoming_delayed_analog_msgs_dispatcher.dispatchIncomingAnalogMsgs(currentStep);
        st_analog_msgs_dispatcher.dispatchAnalogMsgs();         
        currentStep = (min_delay == 0)  ? 0 : ((currentStep+1) % min_delay);
}

void MultiThreadAnalogMsgDispatcher::initialize()
{
}

void MultiThreadAnalogMsgDispatcher::reset(double dt) 
{
        currentStep = 0;        
}

---