X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/390f07ace843ed23ed4d2a1d26f90148d07836ad..92d87d991948c97b02c5a4aec11e9fbc429ce4c6:/src/kernel/actor/ActorImpl.cpp diff --git a/src/kernel/actor/ActorImpl.cpp b/src/kernel/actor/ActorImpl.cpp index 587e847362..4a59ebdcf7 100644 --- a/src/kernel/actor/ActorImpl.cpp +++ b/src/kernel/actor/ActorImpl.cpp @@ -74,7 +74,7 @@ ActorImpl::ActorImpl(xbt::string name, s4u::Host* host) : host_(host), name_(std ActorImpl::~ActorImpl() { - if (simix_global != nullptr && not simix_global->is_maestro(this)) + if (simix_global != nullptr && not EngineImpl::get_instance()->is_maestro(this)) s4u::Actor::on_destruction(*get_ciface()); } @@ -179,7 +179,7 @@ void ActorImpl::cleanup() XBT_DEBUG("%s@%s(%ld) should not run anymore", get_cname(), get_host()->get_cname(), get_pid()); - if (simix_global->is_maestro(this)) /* Do not cleanup maestro */ + if (EngineImpl::get_instance()->is_maestro(this)) /* Do not cleanup maestro */ return; XBT_DEBUG("Cleanup actor %s (%p), waiting synchro %p", get_cname(), this, waiting_synchro_.get()); @@ -236,7 +236,7 @@ void ActorImpl::exit() void ActorImpl::kill(ActorImpl* actor) const { - xbt_assert(not simix_global->is_maestro(actor), "Killing maestro is a rather bad idea"); + xbt_assert(not EngineImpl::get_instance()->is_maestro(actor), "Killing maestro is a rather bad idea"); if (actor->finished_) { XBT_DEBUG("Ignoring request to kill actor %s@%s that is already dead", actor->get_cname(), actor->host_->get_cname()); @@ -335,7 +335,7 @@ void ActorImpl::undaemonize() s4u::Actor* ActorImpl::restart() { - xbt_assert(not simix_global->is_maestro(this), "Restarting maestro is not supported"); + xbt_assert(not EngineImpl::get_instance()->is_maestro(this), "Restarting maestro is not supported"); XBT_DEBUG("Restarting actor %s on %s", get_cname(), host_->get_cname()); @@ -429,11 +429,11 @@ void ActorImpl::throw_exception(std::exception_ptr e) void ActorImpl::simcall_answer() { - if (not simix_global->is_maestro(this)) { + auto* engine = EngineImpl::get_instance(); + if (not engine->is_maestro(this)) { XBT_DEBUG("Answer simcall %s issued by %s (%p)", SIMIX_simcall_name(simcall_), get_cname(), this); xbt_assert(simcall_.call_ != simix::Simcall::NONE); simcall_.call_ = simix::Simcall::NONE; - auto* engine = EngineImpl::get_instance(); const auto& actors_to_run = engine->get_actors_to_run(); xbt_assert(not XBT_LOG_ISENABLED(simix_process, xbt_log_priority_debug) || std::find(begin(actors_to_run), end(actors_to_run), this) == end(actors_to_run), @@ -518,8 +518,8 @@ void create_maestro(const std::function& code) maestro->context_.reset(simix_global->get_context_factory()->create_maestro(ActorCode(code), maestro)); } - maestro->simcall_.issuer_ = maestro; - simix_global->set_maestro(maestro); + maestro->simcall_.issuer_ = maestro; + EngineImpl::get_instance()->set_maestro(maestro); } } // namespace actor