RedundancyCommunicationProtocol.hpp

Go to the documentation of this file.

#ifndef IV_SRC_COMMS_REDUNDANCY_REDUNDANCYCOMMUNICATIONPROTOCOL_HPP
#define IV_SRC_COMMS_REDUNDANCY_REDUNDANCYCOMMUNICATIONPROTOCOL_HPP
 
#include "comms/ICommunicationProtocol.hpp"
#include "comms/redundancy/messages/AbstractRedundancyMessage.hpp"
#include "diamar/AppFailuresLoggerManager.hpp"
 
namespace iv::comms::redundancy
{
 
class RedundancyCommunicationProtocol final : public iv::comms::ICommunicationProtocol
{
public:
    RedundancyCommunicationProtocol() = delete;
    RedundancyCommunicationProtocol(const std::shared_ptr<iv::comms::ICommunicationDriver> &driver,
                                    iv::model::comms::net::IpSettings settings,
                                    const std::weak_ptr<iv::diamar::AppFailuresLoggerManager> &appFailuresLoggerManager,
                                    iv::types::networkId networkId);
    RedundancyCommunicationProtocol(const RedundancyCommunicationProtocol &other) = delete;
    RedundancyCommunicationProtocol(RedundancyCommunicationProtocol &&other) = delete;
    ~RedundancyCommunicationProtocol() override = default;
 
    RedundancyCommunicationProtocol &operator=(const RedundancyCommunicationProtocol &other) = delete;
    RedundancyCommunicationProtocol &operator=(RedundancyCommunicationProtocol &&other) = delete;
 
    [[nodiscard]] bool isOnline() override
    {
        return m_driver->isOnline();
    }
 
    [[nodiscard]] iv::comms::eResponse
    receiveMessage(std::shared_ptr<iv::comms::redundancy::AbstractRedundancyMessage> &message) const;
 
private:
    iv::model::comms::net::IpSettings m_settings;
    std::weak_ptr<iv::diamar::AppFailuresLoggerManager> m_appFailuresLoggerManager;
    iv::types::networkId m_networkId;
};
 
}// namespace iv::comms::redundancy
 
#endif//IV_SRC_COMMS_REDUNDANCY_REDUNDANCYCOMMUNICATIONPROTOCOL_HPP