RedundancyMessageHeartbeat.hpp

Go to the documentation of this file.

#ifndef IV_SRC_COMMS_REDUNDANCY_REDUNDANCYMESSAGEHEARTBEAT_HPP
#define IV_SRC_COMMS_REDUNDANCY_REDUNDANCYMESSAGEHEARTBEAT_HPP
 
#include "channels/AbstractChannel.hpp"
#include "comms/redundancy/messages/AbstractRedundancyMessage.hpp"
#include "streams/OutputStreamMemory.hpp"
 
namespace iv::comms::redundancy
{
 
struct RedundancyMessageHeartbeat final : public iv::comms::redundancy::AbstractRedundancyMessage
{
    iv::types::networkId redundancyNetwork {};
    iv::types::timestamp timestamp {};
    std::map<iv::types::unitId, std::map<iv::comms::eLomLine, iv::types::timestamp>> unitsTimestamps;
 
    RedundancyMessageHeartbeat()
        : AbstractRedundancyMessage(iv::comms::redundancy::eRedundancyMessageType::Heartbeat) {};
 
    void serializeSpecific(std::shared_ptr<iv::streams::OutputStreamMemory> &stream) const override;
    void deserializeSpecific(std::shared_ptr<iv::streams::InputStreamMemory> &stream) override;
 
    static bool
    processHeartbeatMessage(const std::shared_ptr<RedundancyMessageHeartbeat> &message,
                            const std::weak_ptr<iv::channels::AbstractChannel> &heartbeatChannel,
                            const std::weak_ptr<iv::diamar::AppFailuresLoggerManager> &appFailuresLoggerManager,
                            const iv::types::networkId &networkId);
};
 
}// namespace iv::comms::redundancy
 
#endif//IV_SRC_COMMS_REDUNDANCY_REDUNDANCYMESSAGEHEARTBEAT_HPP