Service.h

 
#ifndef WRENCH_SERVICE_H
#define WRENCH_SERVICE_H
 
 
#include <string>
#include <map>
#include <memory>
 
#include "wrench/simgrid_S4U_util/S4U_Daemon.h"
#include "wrench/services/ServiceProperty.h"
#include "wrench/services/ServiceMessagePayload.h"
namespace wrench {
    typedef std::map<WRENCH_PROPERTY_TYPE,std::string> WRENCH_PROPERTY_COLLECTION_TYPE;
    typedef std::unordered_map<WRENCH_MESSAGEPAYLOAD_TYPE ,double> WRENCH_MESSAGE_PAYLOADCOLLECTION_TYPE;
    class FailureCause;
 
class Service : public S4U_Daemon, public std::enable_shared_from_this<Service> {
 
    public:
 
        /***********************/
        /***********************/
 
        void start(std::shared_ptr<Service> this_service, bool daemonize, bool auto_restart);
        virtual void stop();
        void suspend();
        void resume();
 
        std::string getHostname();
        std::string getPhysicalHostname();
 
        bool isUp();
 
        std::string getPropertyValueAsString(WRENCH_PROPERTY_TYPE);
        double getPropertyValueAsDouble(WRENCH_PROPERTY_TYPE);
        unsigned long getPropertyValueAsUnsignedLong(WRENCH_PROPERTY_TYPE);
        bool getPropertyValueAsBoolean(WRENCH_PROPERTY_TYPE);
 
        void assertServiceIsUp();
 
        double getNetworkTimeoutValue();
        void setNetworkTimeoutValue(double value);
 
        /***********************/
        /***********************/
 
        /***********************/
        /***********************/
 
        double getMessagePayloadValue(WRENCH_MESSAGEPAYLOAD_TYPE);
        const WRENCH_MESSAGE_PAYLOADCOLLECTION_TYPE& getMessagePayloadList() const;
 
        void setStateToDown();
 
        /***********************/
        /***********************/
 
    protected:
 
        /***********************/
        /***********************/
 
        static void assertServiceIsUp(std::shared_ptr<Service> s) { s->assertServiceIsUp(); };
 
        friend class Simulation;
 
        ~Service() override;
 
        Service(std::string hostname, std::string process_name_prefix);
 
        // Property stuff
        void setProperty(WRENCH_PROPERTY_TYPE, const std::string&);
 
        void setProperties(WRENCH_PROPERTY_COLLECTION_TYPE default_property_values,
                           WRENCH_PROPERTY_COLLECTION_TYPE overriden_property_values);
 
        // MessagePayload stuff
        void setMessagePayload(WRENCH_MESSAGEPAYLOAD_TYPE, double);
 
        void setMessagePayloads(WRENCH_MESSAGE_PAYLOADCOLLECTION_TYPE default_messagepayload_values,
                                WRENCH_MESSAGE_PAYLOADCOLLECTION_TYPE overriden_messagepayload_values);
 
 
        void serviceSanityCheck();
 
        WRENCH_PROPERTY_COLLECTION_TYPE property_list;
 
        WRENCH_MESSAGE_PAYLOADCOLLECTION_TYPE messagepayload_list;
 
        std::string name;
 
        double network_timeout = 30.0;
 
        template <class T>
        std::shared_ptr<T> getSharedPtr() {
            return std::dynamic_pointer_cast<T>(this->shared_from_this());
        }
 
 
        bool shutting_down = false;
 
    private:
 
        /***********************/
        /***********************/
 
    };
};
 
 
#endif //WRENCH_SERVICE_H