X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/121b00bee831d631cfe3ccd1cf5df8301de47073..593f7525c1fbd75ab6c4f105f9f340401464fe0b:/src/kernel/context/Context.cpp diff --git a/src/kernel/context/Context.cpp b/src/kernel/context/Context.cpp index cdce4e0546..06e540232a 100644 --- a/src/kernel/context/Context.cpp +++ b/src/kernel/context/Context.cpp @@ -5,8 +5,10 @@ #include "mc/mc.h" +#include "simgrid/s4u/Host.hpp" #include "src/kernel/context/Context.hpp" #include "src/simix/smx_private.hpp" +#include "src/surf/surf_interface.hpp" XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(simix_context); @@ -21,7 +23,6 @@ smx_context_t SIMIX_context_new( void_pfn_smxprocess_t cleanup_func, smx_actor_t simix_process) { - xbt_assert(simix_global, "simix is not initialized, please call MSG_init first"); return simix_global->context_factory->create_context( std::move(code), cleanup_func, simix_process); } @@ -82,11 +83,18 @@ Context::~Context() void Context::stop() { + actor_->finished_ = true; + + if (actor_->auto_restart_ && actor_->host_->is_off()) { + XBT_DEBUG("Insert host %s to watched_hosts because it's off and %s needs to restart", actor_->host_->get_cname(), + actor_->get_cname()); + watched_hosts.insert(actor_->host_->get_cname()); + } + if (this->cleanup_func_) this->cleanup_func_(this->actor_); - this->actor_->suspended_ = 0; - this->iwannadie = false; + this->iwannadie = false; // don't let the yield call ourself -- Context::stop() simgrid::simix::simcall([this] { SIMIX_process_cleanup(this->actor_); }); this->iwannadie = true; }