Vehicle-cpp/ZJ_PRO/EgoSystem/radar_ip.h

#pragma once
#include "../common/comm.h"
#include "../common/notifier.h"
#include "../common/iobuffer.h"
#include "../common/sensor_socket.h"
#include <thread>

class CMessageQueue;
 
class CRadarSensor//:public ISensorNotify
{
public:
     CRadarSensor(CMessageQueue *q);
     void Notify(int8_t * buffer,int32_t size);

     void SetSensorSocket(SensorSocket<CRadarSensor>* can);
     void Start();
     void Stop();
     
    // void PreProcess();
private:
     void Run();

private:
     CMessageQueue* _message;
     SensorSocket<CRadarSensor> * _socket;

     bool _run;
     int32_t _count = 0;

     struct RadarData _data;
};