RunSendHeartbeatStation.hpp

Go to the documentation of this file.

#ifndef IV_SRC_THREADS_RUNSENDHEARTBEATSTATION_HPP_
#define IV_SRC_THREADS_RUNSENDHEARTBEATSTATION_HPP_
 
#include "comms/ip/IPCommunicationDriver.hpp"
#include "comms/redundancy/messages/messages.hpp"
#include "core/defines.hpp"
#include "diamar/Station.hpp"
#include "threads/ThreadRunnablePeriodic.hpp"
 
namespace iv::threads
{
 
class RunSendHeartbeatStation final : public iv::threads::ThreadRunnablePeriodic
{
public:
    explicit RunSendHeartbeatStation();
 
private:
    void periodicTask() override;
 
    std::shared_ptr<iv::diamar::Station> m_myStation;
    iv::comms::redundancy::RedundancyMessageHeartbeat m_message;
    std::map<iv::types::ipAddress, iv::types::ipPort> m_toSend;
    std::vector<std::shared_ptr<iv::comms::ip::IPCommunicationDriver>> m_drivers;
};
 
}// namespace iv::threads
 
#endif /* IV_SRC_THREADS_RUNSENDHEARTBEATSTATION_HPP_ */