X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/e6756df2873311a21107025ef1748a3b1c090603..a844d6ba059b98ad6a5317e85a9c69402353b0a9:/src/s4u/s4u_actor.cpp diff --git a/src/s4u/s4u_actor.cpp b/src/s4u/s4u_actor.cpp index 2f97f341a7..444fa6cbc9 100644 --- a/src/s4u/s4u_actor.cpp +++ b/src/s4u/s4u_actor.cpp @@ -12,6 +12,7 @@ #include "simgrid/s4u/host.hpp" #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"); @@ -26,7 +27,7 @@ ActorPtr Actor::self() if (self_context == nullptr) return simgrid::s4u::ActorPtr(); - return simgrid::s4u::ActorPtr(&self_context->process()->actor()); + return simgrid::s4u::ActorPtr(&self_context->process()->getIface()); } @@ -37,7 +38,7 @@ ActorPtr Actor::createActor(const char* name, s4u::Host *host, double killTime, smx_process_t process = simcall_process_create( name, std::move(code), nullptr, host->name().c_str(), killTime, nullptr, 0); - return Ptr(&process->actor()); + return Ptr(&process->getIface()); } ActorPtr Actor::createActor(const char* name, s4u::Host *host, double killTime, @@ -48,7 +49,7 @@ ActorPtr Actor::createActor(const char* name, s4u::Host *host, double killTime, smx_process_t process = simcall_process_create( name, std::move(code), nullptr, host->name().c_str(), killTime, nullptr, 0); - return ActorPtr(&process->actor()); + return ActorPtr(&process->getIface()); } // ***** Actor methods ***** @@ -62,15 +63,19 @@ void Actor::setAutoRestart(bool autorestart) { } s4u::Host *Actor::getHost() { - return simcall_process_get_host(pimpl_); + return pimpl_->host; } -const char* Actor::getName() { - return simcall_process_get_name(pimpl_); +simgrid::xbt::string Actor::getName() { + return pimpl_->name; } int Actor::getPid(){ - return simcall_process_get_PID(pimpl_); + return pimpl_->pid; +} + +int Actor::getPpid() { + return pimpl_->ppid; } void Actor::setKillTime(double time) { @@ -106,7 +111,7 @@ ActorPtr Actor::forPid(int pid) { smx_process_t process = SIMIX_process_from_PID(pid); if (process != nullptr) - return ActorPtr(&process->actor()); + return ActorPtr(&process->getIface()); else return nullptr; } @@ -133,7 +138,7 @@ XBT_PUBLIC(void) sleep_until(double timeout) } e_smx_state_t execute(double flops) { - smx_synchro_t s = simcall_execution_start(nullptr,flops,1.0/*priority*/,0./*bound*/, 0L/*affinity*/); + smx_activity_t s = simcall_execution_start(nullptr,flops,1.0/*priority*/,0./*bound*/); return simcall_execution_wait(s); } @@ -154,7 +159,11 @@ void send(Mailbox &chan, void *payload, size_t simulatedSize) { } int getPid() { - return simcall_process_get_PID(SIMIX_process_self()); + return SIMIX_process_self()->pid; +} + +int getPpid() { + return SIMIX_process_self()->ppid; } }