X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/c8a8ad6adbbd82cb0a9c145b0ac9f563ad62775d..9ea179ce187f56df358fc6f69c3e721b330df272:/src/s4u/s4u_actor.cpp diff --git a/src/s4u/s4u_actor.cpp b/src/s4u/s4u_actor.cpp index 28833f1faf..f16cabf607 100644 --- a/src/s4u/s4u_actor.cpp +++ b/src/s4u/s4u_actor.cpp @@ -13,7 +13,7 @@ #include "src/kernel/context/Context.hpp" -XBT_LOG_NEW_DEFAULT_CATEGORY(s4u_actor,"S4U actors"); +XBT_LOG_NEW_DEFAULT_CATEGORY(s4u_actor, "S4U actors"); namespace simgrid { namespace s4u { @@ -52,11 +52,26 @@ void Actor::setAutoRestart(bool autorestart) { simcall_process_auto_restart_set(pimpl_,autorestart); } +void Actor::onExit(int_f_pvoid_pvoid_t fun, void* data) +{ + simcall_process_on_exit(pimpl_, fun, data); +} + +void Actor::migrate(Host* new_host) +{ + simcall_process_set_host(pimpl_, new_host); +} + s4u::Host* Actor::host() { return this->pimpl_->host; } +const char* Actor::cname() +{ + return this->pimpl_->name.c_str(); +} + simgrid::xbt::string Actor::name() { return this->pimpl_->name; @@ -72,6 +87,21 @@ int Actor::ppid() return this->pimpl_->ppid; } +void Actor::suspend() +{ + simcall_process_suspend(pimpl_); +} + +void Actor::resume() +{ + simcall_process_resume(pimpl_); +} + +int Actor::isSuspended() +{ + return simcall_process_is_suspended(pimpl_); +} + void Actor::setKillTime(double time) { simcall_process_set_kill_time(pimpl_,time); } @@ -82,7 +112,7 @@ double Actor::killTime() } void Actor::kill(int pid) { - msg_process_t process = SIMIX_process_from_PID(pid); + smx_actor_t process = SIMIX_process_from_PID(pid); if(process != nullptr) { simcall_process_kill(process); } else { @@ -111,10 +141,16 @@ ActorPtr Actor::byPid(int pid) return ActorPtr(); } -void Actor::killAll() { +void Actor::killAll() +{ simcall_process_killall(1); } +void Actor::killAll(int resetPid) +{ + simcall_process_killall(resetPid); +} + // ***** this_actor ***** namespace this_actor { @@ -145,7 +181,8 @@ void* recv(MailboxPtr chan) { return res; } -void send(MailboxPtr chan, void *payload, size_t simulatedSize) { +void send(MailboxPtr chan, void* payload, double simulatedSize) +{ Comm& c = Comm::send_init(chan); c.setRemains(simulatedSize); c.setSrcData(payload); @@ -163,6 +200,45 @@ int ppid() return SIMIX_process_self()->ppid; } +std::string name() +{ + return SIMIX_process_self()->name; +} + +Host* host() +{ + return SIMIX_process_self()->host; +} + +void suspend() +{ + simcall_process_suspend(SIMIX_process_self()); +} + +void resume() +{ + simcall_process_resume(SIMIX_process_self()); +} + +int isSuspended() +{ + return simcall_process_is_suspended(SIMIX_process_self()); +} + +void kill() +{ + simcall_process_kill(SIMIX_process_self()); +} + +void onExit(int_f_pvoid_pvoid_t fun, void* data) +{ + simcall_process_on_exit(SIMIX_process_self(), fun, data); +} + +void migrate(Host* new_host) +{ + simcall_process_set_host(SIMIX_process_self(), new_host); +} } } }