SimpleUpdateLoop.hxx

 
#ifndef _DCC_SIMPLEUPDATELOOP_HXX_
#define _DCC_SIMPLEUPDATELOOP_HXX_
 
#include <algorithm>
 
#include "dcc/UpdateLoop.hxx"
#include "executor/StateFlow.hxx"
 
namespace dcc
{
 
class SimpleUpdateLoop : public StateFlow<Buffer<dcc::Packet>, QList<1>>,
                         private UpdateLoopBase
{
public:
    SimpleUpdateLoop(Service *service, TrackIf *track_send);
    ~SimpleUpdateLoop();
 
    bool add_refresh_source(
        dcc::PacketSource *source, unsigned priority) OVERRIDE
    {
        AtomicHolder h(this);
        refreshSources_.push_back(source);
        return true;
    }
 
    void remove_refresh_source(dcc::PacketSource *source) OVERRIDE
    {
        AtomicHolder h(this);
        refreshSources_.erase(
            remove(refreshSources_.begin(), refreshSources_.end(), source),
            refreshSources_.end());
    }
 
    void notify_update(PacketSource *source, unsigned code) OVERRIDE
    {
    }
 
    // Entry to the state flow -- when a new packet needs to be sent.
    Action entry() OVERRIDE;
 
private:
    // Place where we forward the packets filled in.
    TrackIf *trackSend_;
 
    // Packet sources to ask about refreshing data periodically.
    vector<dcc::PacketSource *> refreshSources_;
 
    size_t nextRefreshIndex_;
    long long lastCycleStart_;
};
}
 
#endif // _DCC_SIMPLEUPDATELOOP_HXX_