SimpleUpdateLoop.cxx

Go to the documentation of this file.

 
#include "dcc/SimpleUpdateLoop.hxx"
#include "dcc/Packet.hxx"
#include "dcc/PacketSource.hxx"
 
namespace dcc
{
 
SimpleUpdateLoop::SimpleUpdateLoop(Service *service, TrackIf *track_send)
    : StateFlow(service)
    , trackSend_(track_send)
    , nextRefreshIndex_(0)
    , lastCycleStart_(os_get_time_monotonic())
{
}
 
SimpleUpdateLoop::~SimpleUpdateLoop()
{
}
 
StateFlowBase::Action SimpleUpdateLoop::entry()
{
    long long current_time = os_get_time_monotonic();
    long long prev_cycle_start = lastCycleStart_;
    if (nextRefreshIndex_ >= refreshSources_.size())
    {
        nextRefreshIndex_ = 0;
        lastCycleStart_ = current_time;
    }
    if (nextRefreshIndex_ == 0 &&
        (current_time - prev_cycle_start < MSEC_TO_NSEC(5) ||
         refreshSources_.empty()))
    {
        // We do not want to send another packet to the same locomotive too
        // quick. We send an idle packet instead. OR: We do not have any
        // locomotives at all. We will keep sending idle packets.
        message()->data()->set_dcc_idle();
    }
    else
    {
        // Send an update to the current loco.
        refreshSources_[nextRefreshIndex_]
            ->get_next_packet(0, message()->data());
        nextRefreshIndex_++;
    }
    // We pass on the filled packet to the track processor.
    trackSend_->send(transfer_message());
    return exit();
}
 
} // namespace dcc