X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/fe304706848f0a64477d4687b3ea97d5b9a0c35c..ce930ad96b622e2b3856b7d9c3d97e60ec2c93a1:/include/simgrid/s4u/Exec.hpp diff --git a/include/simgrid/s4u/Exec.hpp b/include/simgrid/s4u/Exec.hpp index 90a2e57d5f..1e9de25b5b 100644 --- a/include/simgrid/s4u/Exec.hpp +++ b/include/simgrid/s4u/Exec.hpp @@ -8,6 +8,7 @@ #include #include +#include #include #include @@ -20,14 +21,11 @@ namespace s4u { * They are generated from this_actor::exec_init() or Host::execute(), and can be used to model pools of threads or * similar mechanisms. */ -class XBT_PUBLIC Exec : public Activity { - std::string name_ = ""; +class XBT_PUBLIC Exec : public Activity_T { double priority_ = 1.0; double bound_ = 0.0; double timeout_ = 0.0; - std::string tracing_category_ = ""; std::atomic_int_fast32_t refcount_{0}; - Host* host_ = nullptr; protected: Exec(); @@ -43,8 +41,8 @@ public: friend XBT_PUBLIC void intrusive_ptr_release(Exec* e); friend XBT_PUBLIC void intrusive_ptr_add_ref(Exec* e); #endif - static xbt::signal on_start; - static xbt::signal on_completion; + static xbt::signal on_start; + static xbt::signal on_completion; virtual Exec* start() override = 0; virtual double get_remaining_ratio() = 0; @@ -61,15 +59,16 @@ public: bool test() override; ExecPtr set_bound(double bound); - ExecPtr set_name(const std::string& name); ExecPtr set_priority(double priority); - ExecPtr set_tracing_category(const std::string& category); ExecPtr set_timeout(double timeout); Exec* cancel() override; const std::string& get_name() const { return name_; } const char* get_cname() const { return name_.c_str(); } - - XBT_ATTRIB_DEPRECATED_v324("Please use Exec::wait_for()") void wait(double t) override { wait_for(t); } + Host* get_host() const; + unsigned int get_host_number() const; + double get_start_time() const; + double get_finish_time() const; + double get_cost() const; }; class XBT_PUBLIC ExecSeq : public Exec { @@ -85,7 +84,6 @@ public: Exec* start() override; ExecPtr set_host(Host* host) override; - Host* get_host(); double get_remaining() override; double get_remaining_ratio() override; @@ -97,7 +95,7 @@ class XBT_PUBLIC ExecPar : public Exec { std::vector bytes_amounts_; explicit ExecPar(const std::vector& hosts, const std::vector& flops_amounts, const std::vector& bytes_amounts); - ExecPtr set_host(Host* host) override { THROW_UNIMPLEMENTED; } + ExecPtr set_host(Host*) override { /* parallel exec cannot be moved */ THROW_UNIMPLEMENTED; } public: ~ExecPar() = default;