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(
                WorkunitExecutor *workunit_executor,
                Workunit *workunit,
                double payload);

        WorkunitExecutor *workunit_executor;
        Workunit *workunit;
    };

    class WorkunitExecutorFailedMessage : public StandardJobExecutorMessage {
    public:
        WorkunitExecutorFailedMessage(
                WorkunitExecutor *workunit_executor,
                Workunit *workunit,
                std::shared_ptr<FailureCause> cause,
                double payload);

        WorkunitExecutor *workunit_executor;
        Workunit *workunit;
        std::shared_ptr<FailureCause> cause;
    };


    class StandardJobExecutorDoneMessage : public StandardJobExecutorMessage {
    public:
        StandardJobExecutorDoneMessage(
                StandardJob *job,
                StandardJobExecutor *executor,
                double payload);

        StandardJobExecutor *executor;
        StandardJob *job;

    };

    class StandardJobExecutorFailedMessage : public StandardJobExecutorMessage {
    public:
        StandardJobExecutorFailedMessage(
                StandardJob *job,
                StandardJobExecutor *executor,
                std::shared_ptr<FailureCause> cause,
                double payload);

        StandardJobExecutor *executor;
        StandardJob *job;
        std::shared_ptr<FailureCause> cause;

    };


    class ComputeThreadDoneMessage : public StandardJobExecutorMessage {
    public:
        ComputeThreadDoneMessage();

    };


    /***********************/
    /***********************/
};

#endif //WRENCH_MULTINODEMULTICORESTANDARDJOBEXECUTORMESSAGE_H