X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/36b13d80aa850a3ce2ac8255f384ac79ec70fb6f..dd1b2a87a1d03d3f69bcef76a5b75e5fa464e593:/src/s4u/s4u_actor.cpp diff --git a/src/s4u/s4u_actor.cpp b/src/s4u/s4u_actor.cpp index 35b65f6a0a..016e38e081 100644 --- a/src/s4u/s4u_actor.cpp +++ b/src/s4u/s4u_actor.cpp @@ -19,25 +19,31 @@ XBT_LOG_NEW_DEFAULT_CATEGORY(s4u_actor,"S4U actors"); namespace simgrid { namespace s4u { -Actor::Actor(const char* name, s4u::Host *host, double killTime, std::function code) +// ***** Actor creation ***** + +ActorPtr Actor::createActor(const char* name, s4u::Host *host, double killTime, std::function code) { // TODO, when autorestart is used, the std::function is copied so the new // instance will get a fresh (reinitialized) state. Is this what we want? - this->pimpl_ = SIMIX_process_ref(simcall_process_create( + smx_process_t process = simcall_process_create( name, std::move(code), nullptr, host->name().c_str(), - killTime, nullptr, 0)); + killTime, nullptr, 0); + return Ptr(&process->actor()); } -Actor::Actor(const char* name, s4u::Host *host, double killTime, +ActorPtr Actor::createActor(const char* name, s4u::Host *host, double killTime, const char* function, std::vector args) { simgrid::simix::ActorCodeFactory& factory = SIMIX_get_actor_code_factory(function); simgrid::simix::ActorCode code = factory(std::move(args)); - this->pimpl_ = SIMIX_process_ref(simcall_process_create( + smx_process_t process = simcall_process_create( name, std::move(code), nullptr, host->name().c_str(), - killTime, nullptr, 0)); + killTime, nullptr, 0); + return ActorPtr(&process->actor()); } +// ***** Actor methods ***** + void Actor::join() { simcall_process_join(pimpl_, -1); } @@ -81,24 +87,27 @@ smx_process_t Actor::getInferior() { return pimpl_; } - void Actor::kill() { simcall_process_kill(pimpl_); } -simgrid::s4u::Actor Actor::forPid(int pid) +// ***** Static functions ***** + +ActorPtr Actor::forPid(int pid) { - // Should we throw if we did not find it? smx_process_t process = SIMIX_process_from_PID(pid); - return simgrid::s4u::Actor(process); + if (process != nullptr) + return ActorPtr(&process->actor()); + else + return nullptr; } -// static stuff: - void Actor::killAll() { simcall_process_killall(1); } +// ***** this_actor ***** + namespace this_actor { void sleep(double duration) {