From: Christian Heinrich Date: Fri, 27 Jul 2018 15:34:44 +0000 (+0200) Subject: [ENERGY] Add new hook to fix issue with communication calls X-Git-Tag: v3_21~341 X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/commitdiff_plain/33bc5a155249e6d47c0d325cc26ac53a71cbff57?hp=84862a5ed2d967524594c4fee1369b3a91c490e3 [ENERGY] Add new hook to fix issue with communication calls See the comment in the commit --- diff --git a/src/plugins/host_energy.cpp b/src/plugins/host_energy.cpp index 4140befa88..be43b29592 100644 --- a/src/plugins/host_energy.cpp +++ b/src/plugins/host_energy.cpp @@ -5,6 +5,7 @@ #include "simgrid/plugins/energy.h" #include "simgrid/s4u/Engine.hpp" +#include "src/kernel/activity/ExecImpl.hpp" #include "src/include/surf/surf.hpp" #include "src/plugins/vm/VirtualMachineImpl.hpp" #include "src/surf/cpu_interface.hpp" @@ -478,6 +479,21 @@ void sg_host_energy_plugin_init() simgrid::s4u::Host::on_destruction.connect(&on_host_destruction); simgrid::s4u::on_simulation_end.connect(&on_simulation_end); simgrid::surf::CpuAction::on_state_change.connect(&on_action_state_change); + // We may only have one actor on a node. If that actor executes something like + // compute -> recv -> compute + // the recv operation will not trigger a "CpuAction::on_state_change". This means + // that the next trigger would be the 2nd compute, hence ignoring the idle time + // during the recv call. By updating at the beginning of a compute, we can + // fix that. (If the cpu is not idle, this is not required.) + simgrid::kernel::activity::ExecImpl::on_creation.connect([](simgrid::kernel::activity::ExecImplPtr activity){ + if (activity->host_ != nullptr) { // We only run on one host + simgrid::s4u::Host* host = activity->host_; + if (dynamic_cast(activity->host_)) + host = dynamic_cast(activity->host_)->get_pm(); + + host->extension()->update(); + } + }); } /** @ingroup plugin_energy