X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/386a691b6ab59cacf781bf1bc0d82acde6b9fafc..808fd3fed0409880a319cae9b6c3ca115c1c01d1:/src/instr/instr_platform.cpp diff --git a/src/instr/instr_platform.cpp b/src/instr/instr_platform.cpp index fe2f6e8bc5..59b16ddcd0 100644 --- a/src/instr/instr_platform.cpp +++ b/src/instr/instr_platform.cpp @@ -229,11 +229,10 @@ static void instr_host_on_speed_change(simgrid::s4u::Host& host) { simgrid::instr::Container::by_name(host.get_cname()) ->get_variable("power") - ->set_event(surf_get_clock(), host.getCoreCount() * host.get_available_speed()); + ->set_event(surf_get_clock(), host.get_core_count() * host.get_available_speed()); } -static void instr_cpu_action_on_state_change(simgrid::surf::CpuAction* action, - simgrid::kernel::resource::Action::State /* previous */) +static void instr_cpu_action_on_state_change(simgrid::surf::CpuAction* action) { simgrid::surf::Cpu* cpu = static_cast(action->get_variable()->get_constraint(0)->get_id()); TRACE_surf_resource_set_utilization("HOST", "power_used", cpu->get_cname(), action->get_category(), @@ -294,6 +293,14 @@ static void instr_actor_on_creation(simgrid::s4u::ActorPtr actor) state->add_entity_value("task_execute", "0 1 1"); root->type_->by_name_or_create("ACTOR_LINK", actor_type, actor_type); root->type_->by_name_or_create("ACTOR_TASK_LINK", actor_type, actor_type); + + actor->on_exit( + [](int status, void* actor) { + if (status == SMX_EXIT_FAILURE) + // kill means that this actor no longer exists, let's destroy it + simgrid::instr::Container::by_name(instr_pid(static_cast(actor)))->remove_from_parent(); + }, + actor->get_impl()); } static long long int counter = 0; @@ -349,7 +356,7 @@ void instr_define_callbacks() } simgrid::s4u::NetZone::onCreation.connect(instr_netzone_on_creation); - simgrid::surf::CpuAction::onStateChange.connect(instr_cpu_action_on_state_change); + simgrid::surf::CpuAction::on_state_change.connect(instr_cpu_action_on_state_change); simgrid::s4u::Link::on_communication_state_change.connect(instr_link_on_communication_state_change); if (TRACE_actor_is_enabled()) {