CloudComputeServiceMessage.h

 
#ifndef WRENCH_CLOUDSERVICEMESSAGE_H
#define WRENCH_CLOUDSERVICEMESSAGE_H
 
#include <vector>
#include "wrench/services/compute/bare_metal/BareMetalComputeService.h"
 
#include "wrench/services/compute/ComputeServiceMessage.h"
 
namespace wrench {
 
    class ComputeService;
 
    /***********************/
    /***********************/
 
    class CloudComputeServiceMessage : public ComputeServiceMessage {
    protected:
        CloudComputeServiceMessage( double payload);
    };
 
    class CloudComputeServiceGetExecutionHostsRequestMessage : public CloudComputeServiceMessage {
    public:
        CloudComputeServiceGetExecutionHostsRequestMessage(simgrid::s4u::Mailbox *answer_mailbox, double payload);
 
        simgrid::s4u::Mailbox *answer_mailbox;
    };
 
    class CloudComputeServiceGetExecutionHostsAnswerMessage : public CloudComputeServiceMessage {
    public:
        CloudComputeServiceGetExecutionHostsAnswerMessage(std::vector<std::string> &execution_hosts, double payload);
 
        std::vector<std::string> execution_hosts;
    };
 
    class CloudComputeServiceCreateVMRequestMessage : public CloudComputeServiceMessage {
    public:
        CloudComputeServiceCreateVMRequestMessage(simgrid::s4u::Mailbox *answer_mailbox,
                                                  unsigned long num_cores,
                                                  double ram_memory,
                                                  std::string desired_vm_name,
                                                  WRENCH_PROPERTY_COLLECTION_TYPE property_list,
                                                  WRENCH_MESSAGE_PAYLOADCOLLECTION_TYPE messagepayload_list,
                                                  double payload);
 
    public:
        simgrid::s4u::Mailbox *answer_mailbox;
        unsigned long num_cores;
        double ram_memory;
        std::string desired_vm_name;
        WRENCH_PROPERTY_COLLECTION_TYPE property_list;
        WRENCH_MESSAGE_PAYLOADCOLLECTION_TYPE messagepayload_list;
    };
 
    class CloudComputeServiceCreateVMAnswerMessage : public CloudComputeServiceMessage {
    public:
        CloudComputeServiceCreateVMAnswerMessage(bool success, std::string &vm_name,
                                                 std::shared_ptr<FailureCause> failure_cause, double payload);
 
        bool success;
        std::string vm_name;
        std::shared_ptr<FailureCause> failure_cause;
    };
 
    class CloudComputeServiceShutdownVMRequestMessage : public CloudComputeServiceMessage {
    public:
        CloudComputeServiceShutdownVMRequestMessage(simgrid::s4u::Mailbox *answer_mailbox,
                                                    const std::string &vm_name,
                                                    bool send_failure_notifications,
                                                    ComputeService::TerminationCause termination_cause,
                                                    double payload);
 
    public:
        simgrid::s4u::Mailbox *answer_mailbox;
        std::string vm_name;
        bool send_failure_notifications;
        ComputeService::TerminationCause termination_cause;
    };
 
    class CloudComputeServiceShutdownVMAnswerMessage : public CloudComputeServiceMessage {
    public:
        CloudComputeServiceShutdownVMAnswerMessage(bool success, std::shared_ptr<FailureCause> failure_cause,
                                                   double payload);
 
        bool success;
        std::shared_ptr<FailureCause> failure_cause;
    };
 
    class CloudComputeServiceStartVMRequestMessage : public CloudComputeServiceMessage {
    public:
        CloudComputeServiceStartVMRequestMessage(simgrid::s4u::Mailbox *answer_mailbox,
                                                 const std::string &vm_name,
                                                 const std::string &pm_name,
                                                 double payload);
 
    public:
        simgrid::s4u::Mailbox *answer_mailbox;
        std::string vm_name;
        std::string pm_name;
    };
 
    class CloudComputeServiceStartVMAnswerMessage : public CloudComputeServiceMessage {
    public:
        CloudComputeServiceStartVMAnswerMessage(bool success,
                                                std::shared_ptr<BareMetalComputeService> cs,
                                                std::shared_ptr<FailureCause> failure_cause,
                                                double payload);
 
        bool success;
        std::shared_ptr<BareMetalComputeService> cs;
        std::shared_ptr<FailureCause> failure_cause;
    };
 
    class CloudComputeServiceSuspendVMRequestMessage : public CloudComputeServiceMessage {
    public:
        CloudComputeServiceSuspendVMRequestMessage(simgrid::s4u::Mailbox *answer_mailbox,
                                                   const std::string &vm_name,
                                                   double payload);
 
    public:
        simgrid::s4u::Mailbox *answer_mailbox;
        std::string vm_name;
    };
 
    class CloudComputeServiceSuspendVMAnswerMessage : public CloudComputeServiceMessage {
    public:
        CloudComputeServiceSuspendVMAnswerMessage(bool success,
                                                  std::shared_ptr<FailureCause> failure_cause,
                                                  double payload);
 
        bool success;
        std::shared_ptr<FailureCause> failure_cause;
    };
 
    class CloudComputeServiceResumeVMRequestMessage : public CloudComputeServiceMessage {
    public:
        CloudComputeServiceResumeVMRequestMessage(simgrid::s4u::Mailbox *mailbox,
                                                  const std::string &vm_name,
                                                  double payload);
 
    public:
        simgrid::s4u::Mailbox *answer_mailbox;
        std::string vm_name;
    };
 
    class CloudComputeServiceResumeVMAnswerMessage : public CloudComputeServiceMessage {
    public:
        CloudComputeServiceResumeVMAnswerMessage(bool success,
                                                 std::shared_ptr<FailureCause> failure_cause,
                                                 double payload);
 
        bool success;
        std::shared_ptr<FailureCause> failure_cause;
    };
 
 
    class CloudComputeServiceDestroyVMRequestMessage : public CloudComputeServiceMessage {
    public:
        CloudComputeServiceDestroyVMRequestMessage(simgrid::s4u::Mailbox *answer_mailbox,
                                                   const std::string &vm_name,
                                                   double payload);
 
    public:
        simgrid::s4u::Mailbox *answer_mailbox;
        std::string vm_name;
    };
 
    class CloudComputeServiceDestroyVMAnswerMessage : public CloudComputeServiceMessage {
    public:
        CloudComputeServiceDestroyVMAnswerMessage(bool success,
                                                  std::shared_ptr<FailureCause> failure_cause,
                                                  double payload);
 
        bool success;
        std::shared_ptr<FailureCause> failure_cause;
    };
 
    /***********************/
    /***********************/
}
 
#endif //WRENCH_CLOUDSERVICEMESSAGE_H