WorkflowJob.h

 
#ifndef WRENCH_WORKFLOWJOB_H
#define WRENCH_WORKFLOWJOB_H
 
 
#include <string>
#include <stack>
#include <map>
#include <memory>
 
//#include "wrench/services/compute/ComputeService.h"
 
namespace wrench {
 
 
    class Workflow;
    class ComputeService;
 
    /***********************/
    /***********************/
 
    class WorkflowJob {
    public:
 
        enum Type {
            STANDARD,
            PILOT
        };
 
        Type getType();
 
        std::string getTypeAsString();
 
        std::string getName();
 
        double getSubmitDate();
 
        /***********************/
        /***********************/
 
        std::string popCallbackMailbox();
 
        void pushCallbackMailbox(std::string);
 
        std::string getCallbackMailbox();
 
        std::string getOriginCallbackMailbox();
 
        void setParentComputeService(std::shared_ptr<ComputeService> compute_service);
 
        std::shared_ptr<ComputeService> getParentComputeService();
 
        std::map<std::string, std::string> getServiceSpecificArguments();
 
        virtual unsigned long getPriority();
 
        virtual ~WorkflowJob();
 
    protected:
 
        friend class JobManager;
 
        WorkflowJob(Type type);
 
        unsigned long getNewUniqueNumber();
 
        std::map<std::string, std::string> service_specific_args;
 
        std::stack<std::string> callback_mailbox_stack;
        Workflow *workflow;
        Type type;
        std::string name;
        double submit_date;
        std::shared_ptr<ComputeService> parent_compute_service;
 
 
    private:
//        bool forward_notification_to_original_source;
 
        /***********************/
        /***********************/
    };
 
    /***********************/
    /***********************/
 
};
 
 
#endif //WRENCH_WORKFLOWJOB_H