linux/spsp/espnow_adapter.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <functional>
#include <string>
#include <thread>
 
#include "spsp/espnow_adapter_if.hpp"
#include "spsp/espnow_packet_ieee80211.hpp"
#include "spsp/espnow_types.hpp"
 
namespace SPSP::LocalLayers::ESPNOW
{
    class Adapter : public IAdapter
    {
    protected:
        struct RawSocket
        {
            int fd;
            RawSocket();
            ~RawSocket();
        };
 
        struct EventFD
        {
            int fd;
            EventFD();
            ~EventFD();
        };
 
        RawSocket m_sock;                               
        EventFD m_eventFd;                              
        int m_epollFd;                                  
        LocalAddrT m_localAddr;                         
        AdapterRecvCb m_recvCb = nullptr;               
        AdapterSendCb m_sendCb = nullptr;               
        std::thread m_thread;                           
 
    public:
        Adapter(const std::string& ifname);
 
        ~Adapter();
 
        void setRecvCb(AdapterRecvCb cb) noexcept { m_recvCb = cb; }
 
        AdapterRecvCb getRecvCb() const noexcept { return m_recvCb; }
 
        void setSendCb(AdapterSendCb cb) noexcept { m_sendCb = cb; }
 
        AdapterSendCb getSendCb() const noexcept { return m_sendCb; }
 
        void send(const LocalAddrT& dst, const std::string& data);
 
        void addPeer(const LocalAddrT& peer) {}
 
        void removePeer(const LocalAddrT& peer) {}
 
    protected:
        void handlerThread();
 
        void attachSocketFilter();
 
        void processIEEE80211RawPacket(const uint8_t* data, size_t len);
 
        bool parseRadiotap(const uint8_t* data, size_t len,
                           IEEE80211::RadiotapParsedFields& rpf);
 
        void processIEEE80211RawAction(const uint8_t* data, size_t len, int rssi);
 
        void processIEEE80211RawAck(const uint8_t* data, size_t len, int rssi);
    };
} // namespace SPSP::LocalLayers::ESPNOW