X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/dbac5943d31dac983835ccccf3e31ff5d3b3e9e4..629bbb0ea28eee8adebd687a0ed72ca9bf110a26:/src/kernel/resource/WifiLinkImpl.cpp diff --git a/src/kernel/resource/WifiLinkImpl.cpp b/src/kernel/resource/WifiLinkImpl.cpp index 0d5ed17801..b0abe21ab5 100644 --- a/src/kernel/resource/WifiLinkImpl.cpp +++ b/src/kernel/resource/WifiLinkImpl.cpp @@ -3,6 +3,7 @@ /* 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. */ +#include #include #include "src/kernel/activity/CommImpl.hpp" @@ -15,6 +16,21 @@ namespace simgrid::kernel::resource { /************ * Resource * ************/ +static void update_bw_comm_start(const s4u::Comm& comm) +{ + auto* pimpl = static_cast(comm.get_impl()); + + auto const* actionWifi = dynamic_cast(pimpl->model_action_); + if (actionWifi == nullptr) + return; + + if (auto* link_src = actionWifi->get_src_link()) { + link_src->inc_active_flux(); + } + if (auto* link_dst = actionWifi->get_dst_link()) { + link_dst->inc_active_flux(); + } +} WifiLinkImpl::WifiLinkImpl(const std::string& name, const std::vector& bandwidths, lmm::System* system) : StandardLinkImpl(name) @@ -22,7 +38,7 @@ WifiLinkImpl::WifiLinkImpl(const std::string& name, const std::vector& b this->set_constraint(system->constraint_new(this, 1)); for (auto bandwidth : bandwidths) bandwidths_.push_back({bandwidth, 1.0, nullptr}); - kernel::activity::CommImpl::on_start.connect(&update_bw_comm_start); + s4u::Comm::on_start_cb(&update_bw_comm_start); s4u::Link::on_communication_state_change_cb(&update_bw_comm_end); } @@ -79,20 +95,6 @@ void WifiLinkImpl::dec_active_flux() nb_active_flux_--; } -void WifiLinkImpl::update_bw_comm_start(const kernel::activity::CommImpl& comm) -{ - auto const* actionWifi = dynamic_cast(comm.model_action_); - if (actionWifi == nullptr) - return; - - if (auto* link_src = actionWifi->get_src_link()) { - link_src->inc_active_flux(); - } - if (auto* link_dst = actionWifi->get_dst_link()) { - link_dst->inc_active_flux(); - } -} - void WifiLinkImpl::update_bw_comm_end(const simgrid::kernel::resource::NetworkAction& action, simgrid::kernel::resource::Action::State /*state*/) {