X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/10ceac5fd14fb0426b5c93bda85676a79b02d0be..a91ed4612675df3eb54e154f6525c3cc96a50b7f:/src/s4u/s4u_actor.cpp diff --git a/src/s4u/s4u_actor.cpp b/src/s4u/s4u_actor.cpp index 1b46b96d40..257717fec6 100644 --- a/src/s4u/s4u_actor.cpp +++ b/src/s4u/s4u_actor.cpp @@ -5,7 +5,6 @@ * under the terms of the license (GNU LGPL) which comes with this package. */ #include "xbt/log.h" -#include "src/msg/msg_private.h" #include "simgrid/s4u/Actor.hpp" #include "simgrid/s4u/comm.hpp" @@ -13,7 +12,6 @@ #include "simgrid/s4u/Mailbox.hpp" #include "src/kernel/context/Context.hpp" -#include "src/simix/smx_private.h" XBT_LOG_NEW_DEFAULT_CATEGORY(s4u_actor,"S4U actors"); @@ -27,62 +25,59 @@ ActorPtr Actor::self() if (self_context == nullptr) return simgrid::s4u::ActorPtr(); - return simgrid::s4u::ActorPtr(&self_context->process()->getIface()); + return self_context->process()->iface(); } - -ActorPtr Actor::createActor(const char* name, s4u::Host *host, double killTime, std::function code) +ActorPtr Actor::createActor(const char* name, s4u::Host* host, 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? - smx_actor_t process = simcall_process_create( - name, std::move(code), nullptr, host->name().c_str(), - killTime, nullptr, 0); - return ActorPtr(&process->getIface()); + smx_actor_t actor = simcall_process_create(name, std::move(code), nullptr, host, nullptr); + return actor->iface(); } -ActorPtr Actor::createActor(const char* name, s4u::Host *host, double killTime, - const char* function, std::vector args) +ActorPtr Actor::createActor(const char* name, s4u::Host* host, const char* function, std::vector args) { simgrid::simix::ActorCodeFactory& factory = SIMIX_get_actor_code_factory(function); simgrid::simix::ActorCode code = factory(std::move(args)); - smx_actor_t process = simcall_process_create( - name, std::move(code), nullptr, host->name().c_str(), - killTime, nullptr, 0); - return ActorPtr(&process->getIface()); + smx_actor_t actor = simcall_process_create(name, std::move(code), nullptr, host, nullptr); + return actor->iface(); } // ***** Actor methods ***** void Actor::join() { - simcall_process_join(pimpl_, -1); + simcall_process_join(this->pimpl_, -1); } void Actor::setAutoRestart(bool autorestart) { simcall_process_auto_restart_set(pimpl_,autorestart); } -s4u::Host *Actor::getHost() { - return pimpl_->host; +s4u::Host* Actor::host() +{ + return this->pimpl_->host; } -simgrid::xbt::string Actor::getName() { - return pimpl_->name; +simgrid::xbt::string Actor::name() +{ + return this->pimpl_->name; } -int Actor::getPid(){ - return pimpl_->pid; +int Actor::pid() +{ + return this->pimpl_->pid; } -int Actor::getPpid() { - return pimpl_->ppid; +int Actor::ppid() +{ + return this->pimpl_->ppid; } void Actor::setKillTime(double time) { simcall_process_set_kill_time(pimpl_,time); } -double Actor::getKillTime() { +double Actor::killTime() +{ return simcall_process_get_kill_time(pimpl_); } @@ -107,13 +102,13 @@ void Actor::kill() { // ***** Static functions ***** -ActorPtr Actor::forPid(int pid) +ActorPtr Actor::byPid(int pid) { smx_actor_t process = SIMIX_process_from_PID(pid); if (process != nullptr) - return ActorPtr(&process->getIface()); + return process->iface(); else - return nullptr; + return ActorPtr(); } void Actor::killAll() { @@ -158,14 +153,20 @@ void send(MailboxPtr chan, void *payload, size_t simulatedSize) { c.wait(); } -int getPid() { +int pid() +{ return SIMIX_process_self()->pid; } -int getPpid() { +int ppid() +{ return SIMIX_process_self()->ppid; } +std::string name() +{ + return SIMIX_process_self()->name; +} } } }