ActionExecutor.h

 
#ifndef WRENCH_ACTION_EXECUTOR_H
#define WRENCH_ACTION_EXECUTOR_H
 
#include <set>
 
#include "wrench/execution_controller/ExecutionController.h"
#include "wrench/services/Service.h"
#include "wrench/action/Action.h"
 
namespace wrench {
 
    class Simulation;
    class Action;
    class ActionExecutionService;
 
    /***********************/
    /***********************/
 
    class ActionExecutor : public ExecutionController {
 
    public:
 
        ActionExecutor(
                std::string hostname,
                unsigned long num_cores,
                double ram_footprint,
                simgrid::s4u::Mailbox *callback_mailbox,
                std::shared_ptr<Action> action,
                std::shared_ptr<ActionExecutionService> action_execution_service);
 
        int main() override;
        void kill(bool job_termination);
        void cleanup(bool has_returned_from_main, int return_value) override;
 
        std::shared_ptr<Action> getAction();
        unsigned long getNumCoresAllocated() const;
        double getMemoryAllocated() const;
 
        std::shared_ptr<ActionExecutionService> getActionExecutionService() const;
 
    private:
 
        std::shared_ptr<Action> action;
        std::shared_ptr<ActionExecutionService> action_execution_service;
        simgrid::s4u::Mailbox *callback_mailbox;
        bool killed_on_purpose;
 
        unsigned long num_cores;
        double ram_footprint;
 
    };
 
    /***********************/
    /***********************/
 
};
 
#endif //WRENCH_ACTION_EXECUTOR_H