X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/6863f9aba274bffb41cd9cb736c9bcb390b64cbf..1c3328f8047e2e5602ed3cd87044ce274e9ff978:/src/plugins/link_energy_wifi.cpp diff --git a/src/plugins/link_energy_wifi.cpp b/src/plugins/link_energy_wifi.cpp index 5bf8bce6f5..8a227c3b21 100644 --- a/src/plugins/link_energy_wifi.cpp +++ b/src/plugins/link_energy_wifi.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2017-2020. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2017-2021. 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. */ @@ -20,7 +20,7 @@ #include SIMGRID_REGISTER_PLUGIN(link_energy_wifi, "Energy wifi test", &sg_wifi_energy_plugin_init); -/** @degroup plugin_link_energy_wifi Plugin WiFi energy +/** @defgroup plugin_link_energy_wifi Plugin WiFi energy * * This is the WiFi energy plugin, accounting for the dissipated energy of WiFi links. */ @@ -31,22 +31,45 @@ namespace simgrid { namespace plugin { class XBT_PRIVATE LinkEnergyWifi { -public: - static simgrid::xbt::Extension EXTENSION_ID; + // associative array keeping size of data already sent for a given flow (required for interleaved actions) + std::map> flowTmp{}; + + // WiFi link the plugin instance is attached to + s4u::Link* link_{}; - explicit LinkEnergyWifi(simgrid::s4u::Link* ptr) : link_(ptr) {} + // dynamic energy accumulated since the simulation start (active durations consumption) + double eDyn_{0.0}; + // static energy (no activity consumption) + double eStat_{0.0}; - ~LinkEnergyWifi() = default; + // duration since previous energy update + double prev_update_{0.0}; + + // Same energy calibration values as ns3 by default + // https://www.nsnam.org/docs/release/3.30/doxygen/classns3_1_1_wifi_radio_energy_model.html#details + double pIdle_{0.82}; + double pTx_{1.14}; + double pRx_{0.94}; + double pSleep_{0.10}; + + // constant taking beacons into account (can be specified by the user) + double control_duration_{0.0036}; + + // Measurements for report + double dur_TxRx_{0}; // Duration of transmission + double dur_idle_{0}; // Duration of idle time + bool valuesInit_{false}; + +public: + static xbt::Extension EXTENSION_ID; + + explicit LinkEnergyWifi(s4u::Link* ptr) : link_(ptr) {} LinkEnergyWifi() = delete; - /** - * Update the energy consumed by link_ when transmissions start or end - */ + /** Update the energy consumed by link_ when transmissions start or end */ void update(const simgrid::kernel::resource::NetworkAction &); - /** - * Update the energy consumed when link_ is destroyed - */ + /** Update the energy consumed when link_ is destroyed */ void update_destroy(); /** @@ -59,12 +82,12 @@ public: */ void init_watts_range_list(); - double get_consumed_energy(void) { return eDyn_ + eStat_; } + double get_consumed_energy(void) const { return eDyn_ + eStat_; } /** Get the dynamic part of the energy for this link */ - double get_energy_dynamic(void) { return eDyn_; } - double get_energy_static(void) { return eStat_; } - double get_duration_comm(void) { return dur_TxRx_; } - double get_duration_idle(void) { return dur_idle_; } + double get_energy_dynamic(void) const { return eDyn_; } + double get_energy_static(void) const { return eStat_; } + double get_duration_comm(void) const { return dur_TxRx_; } + double get_duration_idle(void) const { return dur_idle_; } /** Set the power consumed by this link while idle */ void set_power_idle(double value) { pIdle_ = value; } @@ -74,46 +97,15 @@ public: void set_power_rx(double value) { pRx_ = value; } /** Set the power consumed by this link while sleeping */ void set_power_sleep(double value) { pSleep_ = value; } - -private: - // associative array keeping size of data already sent for a given flow (required for interleaved actions) - std::map> flowTmp{}; - - // WiFi link the plugin instance is attached to - s4u::Link* link_{}; - - // dynamic energy accumulated since the simulation start (active durations consumption) - double eDyn_{0.0}; - // static energy (no activity consumption) - double eStat_{0.0}; - - // duration since previous energy update - double prev_update_{0.0}; - - // Same energy calibration values as ns3 by default - // https://www.nsnam.org/docs/release/3.30/doxygen/classns3_1_1_wifi_radio_energy_model.html#details - double pIdle_{0.82}; - double pTx_{1.14}; - double pRx_{0.94}; - double pSleep_{0.10}; - - // constant taking beacons into account (can be specified by the user) - double control_duration_{0.0036}; - - // Measurements for report - double dur_TxRx_{0}; // Duration of transmission - double dur_idle_{0}; // Duration of idle time - bool valuesInit_{false}; }; xbt::Extension LinkEnergyWifi::EXTENSION_ID; void LinkEnergyWifi::update_destroy() { - simgrid::kernel::resource::NetworkWifiLink* wifi_link = - static_cast(link_->get_impl()); - double duration = surf_get_clock() - prev_update_; - prev_update_ = surf_get_clock(); + auto const* wifi_link = static_cast(link_->get_impl()); + double duration = surf_get_clock() - prev_update_; + prev_update_ = surf_get_clock(); dur_idle_ += duration; @@ -124,7 +116,7 @@ void LinkEnergyWifi::update_destroy() XBT_DEBUG("finish eStat_ += %f * %f * (%d+1) | eStat = %f", duration, pIdle_, wifi_link->get_host_count(), eStat_); } -void LinkEnergyWifi::update(const simgrid::kernel::resource::NetworkAction&) +void LinkEnergyWifi::update(const kernel::resource::NetworkAction&) { init_watts_range_list(); @@ -135,10 +127,8 @@ void LinkEnergyWifi::update(const simgrid::kernel::resource::NetworkAction&) if(duration < 1e-6) return; - simgrid::kernel::resource::NetworkWifiLink* wifi_link = - static_cast(link_->get_impl()); + auto const* wifi_link = static_cast(link_->get_impl()); - const kernel::lmm::Variable* var; const kernel::lmm::Element* elem = nullptr; /** @@ -151,16 +141,14 @@ void LinkEnergyWifi::update(const simgrid::kernel::resource::NetworkAction&) * used by the flow with the longest active time since the previous update */ double durUsage = 0; - while((var = wifi_link->get_constraint()->get_variable(&elem))) { + while (const auto* var = wifi_link->get_constraint()->get_variable(&elem)) { auto* action = static_cast(var->get_id()); - XBT_DEBUG("cost: %f action value: %f link rate 1: %f link rate 2: %f", action->get_cost(), action->get_variable()->get_value(), wifi_link->get_host_rate(&action->get_src()),wifi_link->get_host_rate(&action->get_dst())); - action->get_variable(); + XBT_DEBUG("cost: %f action value: %f link rate 1: %f link rate 2: %f", action->get_cost(), + action->get_variable()->get_value(), wifi_link->get_host_rate(&action->get_src()), + wifi_link->get_host_rate(&action->get_dst())); - double du = 0; // durUsage on the current flow - std::map>::iterator it; - - if(action->get_variable()->get_value()) { - it = flowTmp.find(action); + if (action->get_variable()->get_value() != 0.0) { + auto it = flowTmp.find(action); // if the flow has not been registered, initialize it: 0 bytes sent, and not updated since its creation timestamp if(it == flowTmp.end()) @@ -172,7 +160,8 @@ void LinkEnergyWifi::update(const simgrid::kernel::resource::NetworkAction&) * The active duration of the link is equal to the amount of data it had to send divided by the bandwidth on the link. * If this is longer than the duration since the previous update, active duration = now - previous_update */ - du = (action->get_cost()-it->second.first) / action->get_variable()->get_value(); + double du = // durUsage on the current flow + (action->get_cost() - it->second.first) / action->get_variable()->get_value(); if(du > surf_get_clock()-it->second.second) du = surf_get_clock()-it->second.second; @@ -202,13 +191,13 @@ void LinkEnergyWifi::update(const simgrid::kernel::resource::NetworkAction&) * - if idle i.e. get_usage = 0, update P_{stat} * P_{tot} = P_{dyn}+P_{stat} */ - if(link_->get_usage()){ + if (link_->get_usage() != 0.0) { eDyn_ += /*duration * */ durUsage * ((wifi_link->get_host_count() * pRx_) + pTx_); eStat_ += (duration - durUsage) * pIdle_ * (wifi_link->get_host_count() + 1); XBT_DEBUG("eDyn += %f * ((%d * %f) + %f) | eDyn = %f (durusage =%f)", durUsage, wifi_link->get_host_count(), pRx_, pTx_, eDyn_, durUsage); dur_TxRx_ += duration; - }else{ + } else { dur_idle_ += duration; eStat_ += (duration - (duration * control_duration_)) * pIdle_ * (wifi_link->get_host_count() + 1); } @@ -301,7 +290,7 @@ void sg_wifi_energy_plugin_init() // verify the link is appropriate to WiFi energy computations if (link.get_sharing_policy() == simgrid::s4u::Link::SharingPolicy::WIFI) { XBT_DEBUG("Wifi Link: %s, initialization of wifi energy plugin", link.get_cname()); - LinkEnergyWifi* plugin = new LinkEnergyWifi(&link); + auto* plugin = new LinkEnergyWifi(&link); link.extension_set(plugin); } else { XBT_DEBUG("Not Wifi Link: %s, wifi energy on link not computed", link.get_cname()); @@ -321,9 +310,10 @@ void sg_wifi_energy_plugin_init() }); simgrid::s4u::Link::on_communication_state_change.connect( - [](simgrid::kernel::resource::NetworkAction const& action, simgrid::kernel::resource::Action::State previous) { + [](simgrid::kernel::resource::NetworkAction const& action, + simgrid::kernel::resource::Action::State /* previous */) { // update WiFi links encountered during the communication - for (simgrid::kernel::resource::LinkImpl* link : action.get_links()) { + for (auto const* link : action.get_links()) { if (link != nullptr && link->get_sharing_policy() == simgrid::s4u::Link::SharingPolicy::WIFI) { link->get_iface()->extension()->update(action); } @@ -331,13 +321,13 @@ void sg_wifi_energy_plugin_init() }); simgrid::s4u::Link::on_communicate.connect([](const simgrid::kernel::resource::NetworkAction& action) { - const simgrid::kernel::resource::NetworkWifiAction* actionWifi = dynamic_cast(&action); + auto const* actionWifi = dynamic_cast(&action); if (actionWifi == nullptr) return; - auto link_src = actionWifi->get_src_link(); - auto link_dst = actionWifi->get_dst_link(); + auto const* link_src = actionWifi->get_src_link(); + auto const* link_dst = actionWifi->get_dst_link(); if(link_src != nullptr) link_src->get_iface()->extension()->update(action);