BatchServiceMessage.h

#ifndef WRENCH_BATCHSERVICEMESSAGE_H
#define WRENCH_BATCHSERVICEMESSAGE_H


#include "wrench/services/compute/ComputeServiceMessage.h"
#include "BatchJob.h"

namespace wrench{
    /***********************/
    /***********************/

    class BatchServiceMessage : public ComputeServiceMessage {
    protected:
        BatchServiceMessage(std::string name, double payload);
    };

    class BatchServiceJobRequestMessage : public BatchServiceMessage {
    public:
        BatchServiceJobRequestMessage(std::string answer_mailbox, BatchJob* job , double payload);

        std::string answer_mailbox;
        BatchJob* job;
    };

    class AlarmJobTimeOutMessage : public ServiceMessage {
    public:
        AlarmJobTimeOutMessage(BatchJob* job,double payload);
        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 BatchServiceMessage {
    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 BatchServiceMessage {
    public:
        BatchSchedReadyMessage(std::string answer_mailbox, double payload);

        std::string answer_mailbox;
    };
    #endif


    class BatchExecuteJobFromBatSchedMessage : public BatchServiceMessage {
    public:
        BatchExecuteJobFromBatSchedMessage(std::string answer_mailbox, std::string batsched_decision_reply, double payload);

        std::string answer_mailbox;

        std::string batsched_decision_reply;
    };

    class BatchQueryAnswerMessage : public BatchServiceMessage {
    public:
        BatchQueryAnswerMessage(double estimated_job_start_time, double payload);

        double estimated_start_time;
    };

    #if 0
//    /**
//     * @brief BatchFakeReplyMessage class
//     */
//    class BatchFakeJobSubmissionReplyMessage : public BatchServiceMessage {
//    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 BatchServiceMessage {
    public:
        BatchJobSubmissionToSchedulerMessage(std::string answer_mailbox, WorkflowJob* job, std::string job_args_to_scheduler, double payload);

        std::string answer_mailbox;
        WorkflowJob *job;
        std::string job_args_to_scheduler;
    };
    #endif

    #if 0

    class BatchJobReplyFromSchedulerMessage : public BatchServiceMessage {
    public:
        BatchJobReplyFromSchedulerMessage(std::string, double);

        std::string reply;
    };
    #endif

    /***********************/
    /***********************/

}


#endif //WRENCH_BATCHSERVICEMESSAGE_H