X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/f968cbbb699423fa252994ff42de77f8671ac7eb..27cd66704e3431065a215ff49ee66989bc0f8b4d:/src/surf/HostImpl.cpp diff --git a/src/surf/HostImpl.cpp b/src/surf/HostImpl.cpp index 1084bc0a83..f718d80ada 100644 --- a/src/surf/HostImpl.cpp +++ b/src/surf/HostImpl.cpp @@ -102,6 +102,7 @@ HostImpl::HostImpl(s4u::Host* host) : piface_(host) delete piface_->pimpl_; piface_->pimpl_ = this; } + HostImpl::~HostImpl() { /* All processes should be gone when the host is turned off (by the end of the simulation). */ @@ -113,12 +114,9 @@ HostImpl::~HostImpl() SIMIX_display_process_status(); THROWF(arg_error, 0, "%s", msg.c_str()); } - for (auto const& arg : auto_restart_processes_) - delete arg; - auto_restart_processes_.clear(); - for (auto const& arg : boot_processes_) + for (auto const& arg : actors_at_boot_) delete arg; - boot_processes_.clear(); + actors_at_boot_.clear(); } /** Re-starts all the actors that are marked as restartable. @@ -127,26 +125,38 @@ HostImpl::~HostImpl() */ void HostImpl::turn_on() { - for (auto const& arg : boot_processes_) { - XBT_DEBUG("Booting Process %s(%s) right now", arg->name.c_str(), arg->host->get_cname()); + for (auto const& arg : actors_at_boot_) { + XBT_DEBUG("Booting Actor %s(%s) right now", arg->name.c_str(), arg->host->get_cname()); smx_actor_t actor = simix_global->create_process_function(arg->name.c_str(), arg->code, nullptr, arg->host, arg->properties.get(), nullptr); if (arg->kill_time >= 0) simcall_process_set_kill_time(actor, arg->kill_time); if (arg->auto_restart) actor->auto_restart_ = arg->auto_restart; + if (arg->daemon_) + actor->daemonize(); } } + /** Kill all actors hosted here */ void HostImpl::turn_off() { if (not process_list_.empty()) { for (auto& actor : process_list_) { - SIMIX_process_kill(&actor, SIMIX_process_self()); - XBT_DEBUG("Killing %s@%s on behalf of %s which turned off that host.", actor.get_cname(), + XBT_DEBUG("Killing Actor %s@%s on behalf of %s which turned off that host.", actor.get_cname(), actor.host_->get_cname(), SIMIX_process_self()->get_cname()); + SIMIX_process_kill(&actor, SIMIX_process_self()); } } + // When a host is turned off, we want to keep only the actors that should restart for when it will boot again. + // Then get rid of the others. + auto elm = remove_if(begin(actors_at_boot_), end(actors_at_boot_), [](kernel::actor::ProcessArg* arg) { + if (arg->auto_restart) + return false; + delete arg; + return true; + }); + actors_at_boot_.erase(elm, end(actors_at_boot_)); } std::vector HostImpl::get_all_actors()