Job.h

 
#ifndef WRENCH_JOB_H
#define WRENCH_JOB_H
 
 
#include <string>
#include <stack>
#include <map>
#include <memory>
 
#include "wrench/managers/JobManager.h"
 
namespace wrench {
 
 
    class Workflow;
    class ComputeService;
 
    /***********************/
    /***********************/
 
    class Job {
 
    public:
 
        std::string getName();
 
        double getSubmitDate();
        double getEndDate();
 
        /***********************/
        /***********************/
 
        simgrid::s4u::Mailbox *popCallbackMailbox();
 
        void printCallbackMailboxStack();
 
        void pushCallbackMailbox(simgrid::s4u::Mailbox *mailbox);
 
        simgrid::s4u::Mailbox *getCallbackMailbox();
 
        simgrid::s4u::Mailbox *getOriginCallbackMailbox();
 
        void setParentComputeService(std::shared_ptr<ComputeService> compute_service);
 
        std::shared_ptr<ComputeService> getParentComputeService();
 
 
        virtual ~Job();
 
        virtual void setPriority(double priority);
 
        double getPriority() const;
 
        std::map<std::string, std::string> &getServiceSpecificArguments();
 
    protected:
 
        friend class JobManager;
 
        Job(std::string name, std::shared_ptr<JobManager> job_manager);
 
        void setServiceSpecificArguments(std::map<std::string, std::string> args);
 
        unsigned long getNewUniqueNumber();
 
        std::map<std::string, std::string> service_specific_args;
 
        std::stack<simgrid::s4u::Mailbox *> callback_mailbox_stack;
        std::shared_ptr<JobManager> job_manager;
        simgrid::s4u::Mailbox *originator_mailbox;
 
//        /** @brief The workflow this job belong to */
//        Workflow *workflow;
        std::string name;
        double submit_date;
        double end_date;
        std::shared_ptr<ComputeService> parent_compute_service;
 
        bool already_submitted_to_job_manager = false;
 
        double priority = 0.0;
 
    private:
//        bool forward_notification_to_original_source;
 
 
        /***********************/
        /***********************/
    };
 
    /***********************/
    /***********************/
 
};
 
 
#endif //WRENCH_JOB_H