X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/f051157d903a7e3680081ec4d5fc9d83600847f5..30e0627bbfc12ce4ebeacfda720bc52e95feb22c:/src/plugins/host_load.cpp diff --git a/src/plugins/host_load.cpp b/src/plugins/host_load.cpp index 3484d05f69..a19b7202c5 100644 --- a/src/plugins/host_load.cpp +++ b/src/plugins/host_load.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2010-2022. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2010-2023. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ @@ -10,7 +10,7 @@ #include #include "src/kernel/activity/ExecImpl.hpp" -#include "src/surf/surf_interface.hpp" +#include "src/simgrid/module.hpp" // SIMGRID_REGISTER_PLUGIN // Makes sure that this plugin can be activated from the command line with ``--cfg=plugin:host_load`` SIMGRID_REGISTER_PLUGIN(host_load, "Cpu load", &sg_host_load_plugin_init) @@ -24,18 +24,16 @@ It attaches an extension to each host to store some data, and places callbacks i - :cpp:func:`simgrid::s4u::Host::on_creation_cb`: Attach a new extension to the newly created host. - :cpp:func:`simgrid::s4u::Exec::on_start_cb`: Make note that a new execution started, increasing the load. - :cpp:func:`simgrid::s4u::Exec::on_completion_cb`: Make note that an execution completed, decreasing the load. - - :cpp:func:`simgrid::s4u::Host::on_state_change_cb`: Do what is appropriate when the host gets suspended, turned off - or similar. + - :cpp:func:`simgrid::s4u::Host::on_onoff_cb`: Do what is appropriate when the host gets turned off or on. - :cpp:func:`simgrid::s4u::Host::on_speed_change_cb`: Do what is appropriate when the DVFS is modified. Note that extensions are automatically destroyed when the host gets destroyed. @endrst */ -XBT_LOG_NEW_DEFAULT_SUBCATEGORY(host_load, kernel, "Logging specific to the HostLoad plugin"); +XBT_LOG_NEW_DEFAULT_SUBCATEGORY(host_load, plugin, "Logging specific to the HostLoad plugin"); -namespace simgrid { -namespace plugin { +namespace simgrid::plugin { static const double activity_uninitialized_remaining_cost = -1; @@ -123,9 +121,9 @@ void HostLoad::update() // This loop updates the flops that the host executed for the ongoing computations auto iter = begin(current_activities); while (iter != end(current_activities)) { - auto& activity = iter->first; // Just an alias + const auto& activity = iter->first; // Just an alias auto& remaining_cost_after_last_update = iter->second; // Just an alias - auto& action = activity->surf_action_; + auto& action = activity->model_action_; auto current_iter = iter; ++iter; @@ -190,8 +188,7 @@ void HostLoad::reset() current_flops_ = host_->get_load(); current_speed_ = host_->get_speed(); } -} // namespace plugin -} // namespace simgrid +} // namespace simgrid::plugin using simgrid::plugin::HostLoad; @@ -237,8 +234,7 @@ void sg_host_load_plugin_init() simgrid::s4u::Exec::on_start_cb([](simgrid::s4u::Exec const& activity) { if (activity.get_host_number() == 1) { // We only run on one host simgrid::s4u::Host* host = activity.get_host(); - const simgrid::s4u::VirtualMachine* vm = dynamic_cast(host); - if (vm != nullptr) + if (const auto* vm = dynamic_cast(host)) host = vm->get_pm(); xbt_assert(host != nullptr); host->extension()->add_activity(static_cast(activity.get_impl())); @@ -250,14 +246,10 @@ void sg_host_load_plugin_init() XBT_WARN("HostLoad plugin currently does not support executions on several hosts"); } }); - simgrid::s4u::Activity::on_completion_cb([](simgrid::s4u::Activity const& activity) { - const auto* exec = dynamic_cast(&activity); - if (exec == nullptr) // Only Execs are concerned here - return; - if (exec->get_host_number() == 1) { // We only run on one host - simgrid::s4u::Host* host = exec->get_host(); - const simgrid::s4u::VirtualMachine* vm = dynamic_cast(host); - if (vm != nullptr) + simgrid::s4u::Exec::on_completion_cb([](simgrid::s4u::Exec const& exec) { + if (exec.get_host_number() == 1) { // We only run on one host + simgrid::s4u::Host* host = exec.get_host(); + if (const auto* vm = dynamic_cast(host)) host = vm->get_pm(); xbt_assert(host != nullptr); host->extension()->update(); @@ -265,7 +257,7 @@ void sg_host_load_plugin_init() XBT_WARN("HostLoad plugin currently does not support executions on several hosts"); } }); - simgrid::s4u::Host::on_state_change_cb(&on_host_change); + simgrid::s4u::Host::on_onoff_cb(&on_host_change); simgrid::s4u::Host::on_speed_change_cb(&on_host_change); }