UdpServer.h

Go to the documentation of this file.

#ifndef UdpServer_H
#define UdpServer_H
 
#include "AsioContext.h"
#include "CscCommon.h"
#include <thread>
#include <mutex>
 
using std::thread, std::mutex;
 
namespace conscience_core::communication {
typedef unsigned char BYTE;
 
class UdpServerRuntimeError : public runtime_error {
public:
    UdpServerRuntimeError(const string &message) : runtime_error(message.c_str()) {}
};
 
struct UdpReceiveResponse {
    vector<unsigned char> bytes;
    string remoteIpAddress;
    unsigned int remotePort;
};
 
class UdpServer {
public:
    UdpServer(unsigned int port, function<void(UdpReceiveResponse)> onData);
    ~UdpServer();
 
    unsigned int getPort();
 
private:
    unsigned int port;
    function<void(UdpReceiveResponse)> onData;
 
    class SocketData;
    SocketData *socketData = nullptr;
    
    AsioContext *asioContext = nullptr;
 
    vector<unsigned char> receiveBuffer;
 
    unique_ptr<CscLogger> logger;
 
    void receive();
};
 
}
#endif