HostStateChangeDetector.h

 
#ifndef WRENCH_HOSTSTATECHANGEDETECTOR_H
#define WRENCH_HOSTSTATECHANGEDETECTOR_H
 
#include <wrench/services/Service.h>
#include "wrench/simgrid_S4U_util/S4U_Daemon.h"
#include "HostStateChangeDetectorProperty.h"
 
namespace wrench {
 
    /***********************/
    /***********************/
 
    class HostStateChangeDetector : public Service {
 
    private:
        std::map<std::string, std::string> default_property_values = {
                {HostStateChangeDetectorProperty::MONITORING_PERIOD,                            "1.0"}
        };
 
    public:
 
        explicit HostStateChangeDetector(std::string host_on_which_to_run,
                                         std::vector<std::string> hosts_to_monitor,
                                         bool notify_when_turned_on,
                                         bool notify_when_turned_off,
                                         bool notify_when_speed_change,
                                         std::shared_ptr<S4U_Daemon> creator,
                                         std::string mailbox_to_notify,
                                         std::map<std::string, std::string> property_list = {}
        );
 
        void kill();
 
 
    private:
 
        void cleanup(bool has_terminated_cleanly, int return_value) override;
        void hostStateChangeCallback(std::string const &hostname);
        void hostSpeedChangeCallback(std::string const &hostname);
 
        std::vector<std::string> hosts_to_monitor;
        bool notify_when_turned_on;
        bool notify_when_turned_off;
        bool notify_when_speed_change;
        std::string mailbox_to_notify;
        int main() override;
 
        std::vector<std::pair<std::string, bool>> hosts_that_have_recently_changed_state;
        std::vector<std::pair<std::string, double>> hosts_that_have_recently_changed_speed;
 
        std::shared_ptr<S4U_Daemon> creator;
 
        std::vector<std::string> hosts_that_have_recently_turned_on;
        std::vector<std::string> hosts_that_have_recently_turned_off;
 
        unsigned int on_state_change_call_back_id;
        unsigned int on_speed_change_call_back_id;
 
    };
 
    /***********************/
    /***********************/
 
};
 
 
 
#endif //WRENCH_HOSTSTATECHANGEDETECTOR_H