X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/21f6e059a47df7875f1dacf26ca1eb854f4e887b..7604d0db48006a7a47120a2de9e7152063d5540c:/src/s4u/s4u_Netzone.cpp diff --git a/src/s4u/s4u_Netzone.cpp b/src/s4u/s4u_Netzone.cpp index 06950ef004..139baf6d36 100644 --- a/src/s4u/s4u_Netzone.cpp +++ b/src/s4u/s4u_Netzone.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2006-2022. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2006-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. */ @@ -12,16 +12,10 @@ #include #include -#include "src/kernel/resource/LinkImpl.hpp" -#include "src/kernel/resource/StandardLinkImpl.hpp" +#include "src/kernel/resource/NetworkModel.hpp" -namespace simgrid { -namespace s4u { +namespace simgrid::s4u { -xbt::signal const& link_list)> - NetZone::on_route_creation; xbt::signal NetZone::on_creation; xbt::signal NetZone::on_seal; @@ -45,17 +39,11 @@ void NetZone::set_property(const std::string& key, const std::string& value) std::vector NetZone::get_children() const { std::vector res; - for (auto child : pimpl_->get_children()) + for (auto* child : pimpl_->get_children()) res.push_back(child->get_iface()); return res; } -NetZone* NetZone::add_child(NetZone* new_zone) // XBT_ATTRIB_DEPRECATED_v332 -{ - new_zone->set_parent(this); - return this; -} - const std::string& NetZone::get_name() const { return pimpl_->get_name(); @@ -87,7 +75,7 @@ std::vector NetZone::get_all_hosts() const return pimpl_->get_all_hosts(); } -int NetZone::get_host_count() const +size_t NetZone::get_host_count() const { return pimpl_->get_host_count(); } @@ -97,17 +85,6 @@ unsigned long NetZone::add_component(kernel::routing::NetPoint* elm) return pimpl_->add_component(elm); } -// XBT_ATTRIB_DEPRECATED_v332 -std::vector -NetZone::convert_to_linkInRoute(const std::vector& link_list) -{ - std::vector links; - for (const auto* link : link_list) { - links.emplace_back(LinkInRoute(link->get_iface())); - } - return links; -} - void NetZone::add_route(kernel::routing::NetPoint* src, kernel::routing::NetPoint* dst, kernel::routing::NetPoint* gw_src, kernel::routing::NetPoint* gw_dst, const std::vector& link_list, bool symmetrical) @@ -115,22 +92,6 @@ void NetZone::add_route(kernel::routing::NetPoint* src, kernel::routing::NetPoin pimpl_->add_route(src, dst, gw_src, gw_dst, link_list, symmetrical); } -// XBT_ATTRIB_DEPRECATED_v332 -void NetZone::add_route(kernel::routing::NetPoint* src, kernel::routing::NetPoint* dst, - kernel::routing::NetPoint* gw_src, kernel::routing::NetPoint* gw_dst, - const std::vector& link_list, bool symmetrical) -{ - pimpl_->add_route(src, dst, gw_src, gw_dst, convert_to_linkInRoute(link_list), symmetrical); -} - -// XBT_ATTRIB_DEPRECATED_v332 -void NetZone::add_bypass_route(kernel::routing::NetPoint* src, kernel::routing::NetPoint* dst, - kernel::routing::NetPoint* gw_src, kernel::routing::NetPoint* gw_dst, - const std::vector& link_list, bool /*symmetrical*/) -{ - pimpl_->add_bypass_route(src, dst, gw_src, gw_dst, convert_to_linkInRoute(link_list)); -} - void NetZone::add_bypass_route(kernel::routing::NetPoint* src, kernel::routing::NetPoint* dst, kernel::routing::NetPoint* gw_src, kernel::routing::NetPoint* gw_dst, const std::vector& link_list) @@ -152,6 +113,20 @@ NetZone* NetZone::seal() kernel::actor::simcall_answered([this] { pimpl_->seal(); }); return this; } +void NetZone::set_latency_factor_cb( + std::function& /*links*/, + const std::unordered_set& /*netzones*/)> const& cb) const +{ + kernel::actor::simcall_answered([this, &cb]() { pimpl_->get_network_model()->set_lat_factor_cb(cb); }); +} +void NetZone::set_bandwidth_factor_cb( + std::function& /*links*/, + const std::unordered_set& /*netzones*/)> const& cb) const +{ + kernel::actor::simcall_answered([this, &cb]() { pimpl_->get_network_model()->set_bw_factor_cb(cb); }); +} s4u::Host* NetZone::create_host(const std::string& name, double speed) { @@ -195,8 +170,8 @@ s4u::SplitDuplexLink* NetZone::create_split_duplex_link(const std::string& name, try { speed = xbt_parse_get_bandwidth("", 0, bandwidth, ""); } catch (const simgrid::ParseError&) { - throw std::invalid_argument(std::string("Impossible to create split-duplex link: ") + name + - std::string(". Invalid bandwidth: ") + bandwidth); + throw std::invalid_argument("Impossible to create split-duplex link: " + name + + ". Invalid bandwidth: " + bandwidth); } return create_split_duplex_link(name, speed); } @@ -216,8 +191,7 @@ s4u::Link* NetZone::create_link(const std::string& name, const std::vectorget_netpoint(); } -kernel::resource::NetworkModelIntf* NetZone::get_network_model() const +kernel::resource::NetworkModel* NetZone::get_network_model() const { - kernel::resource::NetworkModelIntf* model = pimpl_->get_network_model().get(); - return model; + return pimpl_->get_network_model().get(); } -} // namespace s4u -} // namespace simgrid +} // namespace simgrid::s4u /* **************************** Public C interface *************************** */