IPCommunicationDriver.hpp

Go to the documentation of this file.

#ifndef IV_SRC_COMMS_IP_IPCOMMUNICATIONDRIVER_HPP_
#define IV_SRC_COMMS_IP_IPCOMMUNICATIONDRIVER_HPP_
 
#include "comms/ICommunicationDriver.hpp"
#include "comms/ip/ITransportProtocol.hpp"
#include "comms/ip/enums.hpp"
 
#include <set>
 
namespace iv::comms::ip
{
 
class IPCommunicationDriver final : public iv::comms::ICommunicationDriver
{
public:
    IPCommunicationDriver() = delete;
    IPCommunicationDriver(const iv::model::comms::net::eIpProtocolLayer &protocolLayer,
                          const iv::comms::ip::eIpNetworkRole &networkRole,
                          const std::set<iv::types::ipAddress> &validIPs);
    ~IPCommunicationDriver() override;
 
    void configure(const iv::model::comms::NetworkData &commConfig) override;
 
    iv::comms::eResponse init() override;
    iv::comms::eResponse end() override;
    iv::comms::eResponse reconnect() override;
    iv::comms::eResponse start() override;
    iv::comms::eResponse stop() override;
 
    [[nodiscard]] iv::comms::eResponse receive(std::vector<std::byte> &buffer, iv::types::ipAddress *ip,
                                               iv::types::ipPort *port);
    iv::comms::eResponse send(const std::vector<std::byte> &data, const iv::types::ipAddress &ip,
                              iv::types::ipPort port);
 
    bool isOnline() override;
 
    std::set<std::string> m_validIPs;
    iv::types::ipAddress m_ip {};
    iv::types::ipPort m_port {0};
 
private:
    iv::types::timestamp m_lastTimePacketReceived {0};
 
    uint64_t m_readingRetriesWithoutData {0};
 
    iv::model::comms::net::eIpProtocolLayer m_protocolLayer;
    iv::comms::ip::eIpNetworkRole m_networkRole;
 
    std::mutex m_driverMutex;
 
    iv::comms::ip::ITransportProtocol *m_socketOpt;
};
 
}// namespace iv::comms::ip
 
#endif//IV_SRC_COMMS_IP_IPCOMMUNICATIONDRIVER_HPP_