CC32xxEEPROMFlushFlow.hxx

Go to the documentation of this file.

 
#ifndef FREERTOS_DRIVERS_TI_CC32XXEEPROMFLUSHFLOW_HXX_
#define FREERTOS_DRIVERS_TI_CC32XXEEPROMFLUSHFLOW_HXX_
 
#include "executor/StateFlow.hxx"
 
extern "C" {
void eeprom_flush();
}
 
class EepromTimerFlow : public StateFlowBase, protected Atomic
{
public:
    EepromTimerFlow(Service* s)
        : StateFlowBase(s)
        , isWaiting_(0)
        , isDirty_(0)
    {
        start_flow(STATE(test_and_sleep));
    }
 
    void wakeup() {
        AtomicHolder h(this);
        isDirty_ = 1;
        if (isWaiting_) {
            isWaiting_ = 0;
            notify();
        }
    }
 
private:
    Action test_and_sleep()
    {
        bool need_sleep = false;
        {
            AtomicHolder h(this);
            if (isDirty_)
            {
                isDirty_ = 0;
                need_sleep = true;
            }
            else
            {
                isWaiting_ = 1;
            }
        }
        if (need_sleep)
        {
            return sleep_and_call(
                &timer_, MSEC_TO_NSEC(1000), STATE(test_and_flush));
        }
        else
        {
            return wait();
        }
    }
 
    Action test_and_flush()
    {
        bool need_sleep = false;
        {
            AtomicHolder h(this);
            if (isDirty_)
            {
                // we received another write during the sleep. Go back to sleep.
                isDirty_ = 0;
                need_sleep = true;
            }
        }
        if (need_sleep)
        {
            return sleep_and_call(
                &timer_, MSEC_TO_NSEC(1000), STATE(test_and_flush));
        }
        eeprom_flush();
        return call_immediately(STATE(test_and_sleep));
    }
 
    StateFlowTimer timer_{this};
    // 1 if the flow is sleeping and needs to be notified to wake up.
    unsigned isWaiting_ : 1;
    // 1 if we received a notification from the eeprom handler.
    unsigned isDirty_ : 1;
};
 
extern EepromTimerFlow eepromTimerFlow_;
 
#ifndef SKIP_UPDATED_CALLBACK
extern "C" {
void eeprom_updated_notification() {
    eepromTimerFlow_.wakeup();
}
}
#endif
 
#endif // FREERTOS_DRIVERS_TI_CC32XXEEPROMFLUSHFLOW_HXX_