RMMUDPCore.h

#pragma once
 
#include <iostream>
#include <json.hpp>
#include <string>
 
#include "RMMRegisterAccess.h"
#include "RMMUtils.h"
using json = nlohmann::json;

struct ArpLut {
  std::string destinationIP;   
  std::string destinationMAC;  
  uint32_t destinationPort;    
};

struct UDPCoreData {
  std::string sourceMAC;          
  std::string sourceIP;           
  uint32_t sourcePort;            
  float arpRefreshTimeout;        
  float arpReplyTimeout;          
  std::map<uint8_t, ArpLut> lut;  
};

class RMMUDPCore {
 public:
  RMMUDPCore(RMMRegisterAccess& RMMRegs);
  void configUDPCore();
  rmmStatus arpStatus(const int index, std::unordered_map<std::string, int>* status);
  RMMLog rmmLog;  
  rmmStatus getUdpCoreData(UDPCoreData* result);
  void processMap();
  bool fillUDPMutexes(uint8_t index);
  void fillUdpCoreFromJson(json& udpCoreCfg);
 
 private:
  RMMRegisterAccess& RMMRegs;
  uint32_t base_address;
  UDPCoreData udpCore;
 
  void disableARP();
  void enableARP();
  void writeUDPCoreReg(std::string reg, uint32_t data, int index = -1);
  uint32_t readUDPCoreReg(std::string reg, int index = -1);
  uint32_t getUDPCoreAbsAddr(std::string reg, int index = -1);
  void setARPTimeouts(float refresh_timeout = 1228.7, float reply_timeout = 25.5);
  void clearDestinationLUTARP();
  void addDestinationLUTEntry(uint8_t index, std::string ip, uint32_t port, std::string mac_str = "");
};