StandardJobExecutorMessage.h

 
#ifndef WRENCH_MULTINODEMULTICORESTANDARDJOBEXECUTORMESSAGE_H
#define WRENCH_MULTINODEMULTICORESTANDARDJOBEXECUTORMESSAGE_H
 
#include <vector>
 
#include "wrench/services/compute/workunit_executor/WorkunitExecutor.h"
#include "wrench/services/compute/ComputeServiceMessage.h"
 
namespace wrench {
 
    class WorkflowTask;
 
    class StandardJobExecutor;
 
    class WorkunitMultiCoreExecutor;
 
    /***********************/
    /***********************/
 
    class StandardJobExecutorMessage : public SimulationMessage {
    protected:
        StandardJobExecutorMessage(std::string name, double payload);
    };
 
    class WorkunitExecutorDoneMessage : public StandardJobExecutorMessage {
    public:
        WorkunitExecutorDoneMessage(
                std::shared_ptr<WorkunitExecutor> workunit_executor,
                std::shared_ptr<Workunit> workunit,
                double payload);
 
        std::shared_ptr<WorkunitExecutor> workunit_executor;
        std::shared_ptr<Workunit> workunit;
    };
 
    class WorkunitExecutorFailedMessage : public StandardJobExecutorMessage {
    public:
        WorkunitExecutorFailedMessage(
                std::shared_ptr<WorkunitExecutor> workunit_executor,
                std::shared_ptr<Workunit> workunit,
                std::shared_ptr<FailureCause> cause,
                double payload);
 
        std::shared_ptr<WorkunitExecutor> workunit_executor;
        std::shared_ptr<Workunit> workunit;
        std::shared_ptr<FailureCause> cause;
    };
 
 
    class StandardJobExecutorDoneMessage : public StandardJobExecutorMessage {
    public:
        StandardJobExecutorDoneMessage(
                StandardJob *job,
                std::shared_ptr<StandardJobExecutor> executor,
                double payload);
 
        std::shared_ptr<StandardJobExecutor> executor;
        StandardJob *job;
 
    };
 
    class StandardJobExecutorFailedMessage : public StandardJobExecutorMessage {
    public:
        StandardJobExecutorFailedMessage(
                StandardJob *job,
                std::shared_ptr<StandardJobExecutor> executor,
                std::shared_ptr<FailureCause> cause,
                double payload);
 
        std::shared_ptr<StandardJobExecutor> executor;
        StandardJob *job;
        std::shared_ptr<FailureCause> cause;
 
    };
 
 
    class ComputeThreadDoneMessage : public StandardJobExecutorMessage {
    public:
        ComputeThreadDoneMessage();
 
    };
 
 
    /***********************/
    /***********************/
};
 
#endif //WRENCH_MULTINODEMULTICORESTANDARDJOBEXECUTORMESSAGE_H