V2XConnector.h

 
#ifndef SIM_TO_DUT_INTERFACE_V2XCONNECTOR_H
#define SIM_TO_DUT_INTERFACE_V2XCONNECTOR_H
 
#include "../DuTConnector.h"
#include <curl/curl.h>
#include <thread>
#include "V2XConnectorConfig.h"
 
namespace sim_interface::dut_connector::v2x {
    class V2XConnector : public DuTConnector {
 
    public:
        explicit V2XConnector(std::shared_ptr<SharedQueue < SimEvent>>
 
        queueDuTToSim,
        const V2XConnectorConfig &config
        );
 
        ~V2XConnector();
 
        void handleEventSingle(const SimEvent &e) override;
 
        ConnectorInfo getConnectorInfo() override;
 
    private:
        void receiveCallback(const std::vector<unsigned char> &msg);
 
        void startReceive();
 
        void onReceive(const boost::system::error_code &ec, std::size_t read_bytes);
 
        static int getIfnameIndex(const std::string &ifname);
 
        boost::asio::io_service ioService;
 
        boost::asio::generic::raw_protocol::socket _socket;
 
        std::vector<unsigned char> receiveBuffer;
 
        boost::asio::generic::raw_protocol::endpoint receiveEndpoint;
 
        std::thread sockRunner;
 
        unsigned short ethernetFrameType;
    };
}
 
 
#endif //SIM_TO_DUT_INTERFACE_V2XCONNECTOR_H