RedundancyMessageChannel.hpp

Go to the documentation of this file.

#ifndef IV_SRC_COMMS_REDUNDANCY_REDUNDANCYMESSAGECHANNEL_HPP
#define IV_SRC_COMMS_REDUNDANCY_REDUNDANCYMESSAGECHANNEL_HPP
 
#include "channels/AbstractChannel.hpp"
#include "comms/redundancy/messages/AbstractRedundancyMessage.hpp"
#include "streams/OutputStreamMemory.hpp"
 
namespace iv::comms::redundancy
{
 
enum eChannelMessageType
{
    Periodic = 0,
    Expeditive = 1//Sent after an update in the channel value
};
 
struct RedundancyMessageChannel final : public iv::comms::redundancy::AbstractRedundancyMessage
{
    iv::types::networkId m_network;
    iv::types::unitId m_unit {};
    iv::types::channelId m_channel;
    iv::channels::Value m_value {};
    iv::alarms::Alarm m_alarm {};
    eChannelMessageType m_messageType {eChannelMessageType::Periodic};
 
    RedundancyMessageChannel() : AbstractRedundancyMessage(iv::comms::redundancy::eRedundancyMessageType::Channel)
    {
    }
 
    RedundancyMessageChannel(iv::types::networkId network, iv::types::unitId unit, iv::types::channelId channel,
                             iv::channels::Value value, iv::alarms::Alarm alarm, eChannelMessageType messageType);
 
    void serializeSpecific(std::shared_ptr<iv::streams::OutputStreamMemory> &stream) const override;
    void deserializeSpecific(std::shared_ptr<iv::streams::InputStreamMemory> &stream) override;
 
    static bool processChannelMessage(
            const std::shared_ptr<RedundancyMessageChannel> &message,
            const std::map<iv::types::channelId, std::shared_ptr<iv::channels::AbstractChannel>> &channels,
            const std::weak_ptr<iv::diamar::AppFailuresLoggerManager> &appFailuresLoggerManager,
            const iv::types::networkId &networkId);
 
    // TODO: Hacer en otro sitio
    static std::optional<iv::types::stationId>
    isCommunicationError(const std::shared_ptr<RedundancyMessageChannel> &message);
};
 
}// namespace iv::comms::redundancy
 
#endif//IV_SRC_COMMS_REDUNDANCY_REDUNDANCYMESSAGECHANNEL_HPP