BatchComputeServiceMessage.h

 
#ifndef WRENCH_BATCHSERVICEMESSAGE_H
#define WRENCH_BATCHSERVICEMESSAGE_H
 
 
#include "wrench/services/compute/ComputeServiceMessage.h"
#include "BatchJob.h"
 
namespace wrench{
    /***********************/
    /***********************/
 
    class BatchComputeServiceMessage : public ComputeServiceMessage {
    protected:
        BatchComputeServiceMessage( double payload);
    };
 
    class BatchComputeServiceJobRequestMessage : public BatchComputeServiceMessage {
    public:
        BatchComputeServiceJobRequestMessage(simgrid::s4u::Mailbox *answer_mailbox, std::shared_ptr<BatchJob> job , double payload);
 
        simgrid::s4u::Mailbox *answer_mailbox;
        std::shared_ptr<BatchJob> job;
    };
 
    class AlarmJobTimeOutMessage : public ServiceMessage {
    public:
        AlarmJobTimeOutMessage(std::shared_ptr<BatchJob> job,double payload);
        std::shared_ptr<BatchJob> job;
    };
 
    #if 0
 
    class AlarmNotifyBatschedMessage : public ServiceMessage {
    public:
        AlarmNotifyBatschedMessage(std::string job_id, double payload);
        std::string job_id;
    };
    #endif
 
#if 0
 
    class BatchSimulationBeginsToSchedulerMessage : public BatchComputeServiceMessage {
    public:
        BatchSimulationBeginsToSchedulerMessage(std::string answer_mailbox, std::string job_args_to_scheduler, double payload);
 
        std::string answer_mailbox;
        std::string job_args_to_scheduler;
    };
#endif
 
    #if 0
 
    class BatchSchedReadyMessage : public BatchComputeServiceMessage {
    public:
        BatchSchedReadyMessage(std::string answer_mailbox, double payload);
 
        std::string answer_mailbox;
    };
    #endif
 
 
    class BatchExecuteJobFromBatSchedMessage : public BatchComputeServiceMessage {
    public:
        BatchExecuteJobFromBatSchedMessage(simgrid::s4u::Mailbox *answer_mailbox, std::string batsched_decision_reply, double payload);
 
        simgrid::s4u::Mailbox *answer_mailbox;
 
        std::string batsched_decision_reply;
    };
 
    class BatchQueryAnswerMessage : public BatchComputeServiceMessage {
    public:
        BatchQueryAnswerMessage(double estimated_job_start_time, double payload);
 
        double estimated_start_time;
    };
 
    #if 0
//    /**
//     * @brief BatchFakeReplyMessage class
//     */
//    class BatchFakeJobSubmissionReplyMessage : public BatchComputeServiceMessage {
//    public:
//        BatchFakeJobSubmissionReplyMessage(std::string json_data_string, double payload);
//
//        /** @brief The resources info in json data string */
//        std::string json_data_string;
//    };
    #endif
 
 
    #if 0
 
    class BatchJobSubmissionToSchedulerMessage : public BatchComputeServiceMessage {
    public:
        BatchJobSubmissionToSchedulerMessage(simgrid::s4u::Mailbox *answer_mailbox, Job* job, std::string job_args_to_scheduler, double payload);
 
        simgrid::s4u::Mailbox *answer_mailbox;
        Job *job;
        std::string job_args_to_scheduler;
    };
    #endif
 
    #if 0
 
    class BatchJobReplyFromSchedulerMessage : public BatchComputeServiceMessage {
    public:
        BatchJobReplyFromSchedulerMessage(std::string, double);
 
        std::string reply;
    };
    #endif
 
    /***********************/
    /***********************/
 
}
 
 
#endif //WRENCH_BATCHSERVICEMESSAGE_H