X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/c91b5a0dff704f2fe08d3480a12cc15f1a8b4081..af459dff2b5461c2dbc61e5b5cbdc302f92d2404:/src/simix/ActorImpl.hpp?ds=sidebyside diff --git a/src/simix/ActorImpl.hpp b/src/simix/ActorImpl.hpp index 03966bf846..0b4c9e6d46 100644 --- a/src/simix/ActorImpl.hpp +++ b/src/simix/ActorImpl.hpp @@ -25,11 +25,23 @@ class ProcessArg { public: std::string name; std::function code; - void *data = nullptr; - sg_host_t host = nullptr; + void* data = nullptr; + s4u::Host* host = nullptr; double kill_time = 0.0; std::shared_ptr> properties; bool auto_restart = false; + ProcessArg() = default; + explicit ProcessArg(std::string name, std::function code, void* data, s4u::Host* host, double kill_time, + std::shared_ptr> properties, bool auto_restart) + : name(name) + , code(std::move(code)) + , data(data) + , host(host) + , kill_time(kill_time) + , properties(properties) + , auto_restart(auto_restart) + { + } }; class ActorImpl : public simgrid::surf::PropertyHolder { @@ -56,7 +68,6 @@ public: bool suspended = false; bool auto_restart = false; - sg_host_t new_host = nullptr; /* if not null, the host on which the process must migrate to */ smx_activity_t waiting_synchro = nullptr; /* the current blocking synchro if any */ std::list comms; /* the current non-blocking communication synchros */ s_smx_simcall_t simcall; @@ -113,6 +124,10 @@ public: void* getUserData() { return userdata; } }; +/* Used to keep the list of actors blocked on a synchro */ +typedef boost::intrusive::list, + &ActorImpl::smx_synchro_hook>> + SynchroList; } }