BootloaderPort.hxx

Go to the documentation of this file.

 
#ifndef _OPENLCB_BOOTLOADERPORT_HXX_
#define _OPENLCB_BOOTLOADERPORT_HXX_
 
#include "utils/Hub.hxx"
 
namespace openlcb {
 
class BootloaderPort : public CanHubPort
{
public:
    BootloaderPort(Service* service)
        : CanHubPort(service)
    {
        is_waiting_ = false;
    }
 
    bool is_waiting()
    {
        return is_waiting_;
    }
 
    Action entry() override
    {
        AtomicHolder h(this);
        is_waiting_ = true;
        return wait_and_call(STATE(sent));
    }
 
    Action sent()
    {
        return release_and_exit();
    }
 
    bool read_can_frame(struct can_frame *frame)
    {
        {
            AtomicHolder h(this);
            if (is_waiting_)
            {
                *frame = *message()->data();
                is_waiting_ = false;
            }
            else
            {
                return false;
            }
        }
        notify();
        return true;
    }
 
private:
    bool is_waiting_ = false;
};
 
}  // namespace openlcb
 
#endif //_OPENLCB_BOOTLOADERPORT_HXX_