X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/dbac5943d31dac983835ccccf3e31ff5d3b3e9e4..629bbb0ea28eee8adebd687a0ed72ca9bf110a26:/src/plugins/link_load.cpp diff --git a/src/plugins/link_load.cpp b/src/plugins/link_load.cpp index d502cec4df..8f0937d36c 100644 --- a/src/plugins/link_load.cpp +++ b/src/plugins/link_load.cpp @@ -4,6 +4,7 @@ * under the terms of the license (GNU LGPL) which comes with this package. */ #include +#include #include #include "src/kernel/activity/CommImpl.hpp" @@ -161,9 +162,10 @@ double LinkLoad::get_average_bytes() using simgrid::plugin::LinkLoad; /* **************************** events callback *************************** */ -static void on_communication(const simgrid::kernel::activity::CommImpl& comm) +static void on_communication(const simgrid::s4u::Comm& comm) { - for (const auto* link : comm.get_traversed_links()) { + auto* pimpl = static_cast(comm.get_impl()); + for (auto const* link : pimpl->get_traversed_links()) { if (link != nullptr && link->get_sharing_policy() != simgrid::s4u::Link::SharingPolicy::WIFI) { auto* link_load = link->extension(); XBT_DEBUG("Update %s on Comm Start/End", link->get_cname()); @@ -199,8 +201,8 @@ void sg_link_load_plugin_init() }); // Call this plugin on some of the links' events. - simgrid::kernel::activity::CommImpl::on_start.connect(&on_communication); - simgrid::kernel::activity::CommImpl::on_completion.connect(&on_communication); + simgrid::s4u::Comm::on_start_cb(&on_communication); + simgrid::s4u::Comm::on_completion_cb(&on_communication); simgrid::s4u::Link::on_onoff_cb([](simgrid::s4u::Link const& link) { if (link.get_sharing_policy() != simgrid::s4u::Link::SharingPolicy::WIFI) {