X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/1365d67fed75eed3bc33aaed77aac4481039f27a..c687db88634134fbe8109bbbcbf09130928bec27:/src/s4u/s4u_Netzone.cpp?ds=sidebyside diff --git a/src/s4u/s4u_Netzone.cpp b/src/s4u/s4u_Netzone.cpp index fa6f0c2d26..4ca7bd758f 100644 --- a/src/s4u/s4u_Netzone.cpp +++ b/src/s4u/s4u_Netzone.cpp @@ -10,6 +10,7 @@ #include "simgrid/s4u/NetZone.hpp" #include "simgrid/simix.hpp" #include "simgrid/zone.h" +#include "src/surf/network_interface.hpp" #include "xbt/parse_units.hpp" namespace simgrid { @@ -42,14 +43,14 @@ 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(const NetZone* new_zone) +NetZone* NetZone::add_child(NetZone* new_zone) { - pimpl_->add_child(new_zone->get_impl()); + new_zone->set_parent(this); return this; } @@ -75,7 +76,7 @@ NetZone* NetZone::get_parent() const NetZone* NetZone::set_parent(const NetZone* parent) { - pimpl_->set_parent(parent->get_impl()); + kernel::actor::simcall([this, parent] { pimpl_->set_parent(parent->get_impl()); }); return this; } @@ -99,39 +100,44 @@ int NetZone::add_component(kernel::routing::NetPoint* elm) return pimpl_->add_component(elm); } -std::vector NetZone::get_link_list_impl(const std::vector link_list) +// 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.push_back(link->get_impl()); + std::vector links; + for (const auto* link : link_list) { + links.emplace_back(LinkInRoute(link->get_iface())); } return links; } -void NetZone::add_regular_route(kernel::routing::NetPoint* src, kernel::routing::NetPoint* dst, - const std::vector& link_list, bool symmetrical) -{ - add_route(src, dst, nullptr, nullptr, NetZone::get_link_list_impl(link_list), symmetrical); -} - -void NetZone::add_netzone_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) +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) { - add_route(src, dst, gw_src, gw_dst, NetZone::get_link_list_impl(link_list), symmetrical); + 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, link_list, 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, - std::vector& link_list, bool symmetrical) + std::vector& link_list, bool /*symmetrical*/) { - pimpl_->add_bypass_route(src, dst, gw_src, gw_dst, link_list, 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) +{ + pimpl_->add_bypass_route(src, dst, gw_src, gw_dst, link_list); } void NetZone::extract_xbt_graph(const s_xbt_graph_t* graph, std::map>* nodes, @@ -143,40 +149,97 @@ void NetZone::extract_xbt_graph(const s_xbt_graph_t* graph, std::mapget_graph(graph, nodes, edges); } +NetZone* NetZone::seal() +{ + kernel::actor::simcall([this] { pimpl_->seal(); }); + return this; +} + +s4u::Host* NetZone::create_host(const std::string& name, double speed) +{ + return create_host(name, std::vector{speed}); +} + s4u::Host* NetZone::create_host(const std::string& name, const std::vector& speed_per_pstate) { return kernel::actor::simcall( [this, &name, &speed_per_pstate] { return pimpl_->create_host(name, speed_per_pstate); }); } + +s4u::Host* NetZone::create_host(const std::string& name, const std::string& speed) +{ + return create_host(name, std::vector{speed}); +} + s4u::Host* NetZone::create_host(const std::string& name, const std::vector& speed_per_pstate) { return create_host(name, Host::convert_pstate_speed_vector(speed_per_pstate)); } -s4u::Link* NetZone::create_link(const std::string& name, const std::vector& bandwidths, - s4u::Link::SharingPolicy policy) +s4u::Link* NetZone::create_link(const std::string& name, double bandwidth) +{ + return create_link(name, std::vector{bandwidth}); +} + +s4u::Link* NetZone::create_link(const std::string& name, const std::vector& bandwidths) +{ + return kernel::actor::simcall([this, &name, &bandwidths] { return pimpl_->create_link(name, bandwidths); }); +} + +s4u::Link* NetZone::create_link(const std::string& name, const std::string& bandwidth) +{ + return create_link(name, std::vector{bandwidth}); +} + +s4u::SplitDuplexLink* NetZone::create_split_duplex_link(const std::string& name, const std::string& bandwidth) +{ + double speed; + 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); + } + return create_split_duplex_link(name, speed); +} + +s4u::SplitDuplexLink* NetZone::create_split_duplex_link(const std::string& name, double bandwidth) { return kernel::actor::simcall( - [this, &name, &bandwidths, &policy] { return pimpl_->create_link(name, bandwidths, policy); }); + [this, &name, &bandwidth] { return pimpl_->create_split_duplex_link(name, std::vector{bandwidth}); }); } -s4u::Link* NetZone::create_link(const std::string& name, const std::vector& bandwidths, - s4u::Link::SharingPolicy policy) +s4u::Link* NetZone::create_link(const std::string& name, const std::vector& bandwidths) { std::vector bw; bw.reserve(bandwidths.size()); for (const auto& speed_str : bandwidths) { try { - double speed = xbt_parse_get_bandwidth("", 0, speed_str.c_str(), nullptr, ""); + double speed = xbt_parse_get_bandwidth("", 0, speed_str, ""); bw.push_back(speed); } catch (const simgrid::ParseError&) { throw std::invalid_argument(std::string("Impossible to create link: ") + name + std::string(". Invalid bandwidth: ") + speed_str); } } - return create_link(name, bw, policy); + return create_link(name, bw); +} + +kernel::routing::NetPoint* NetZone::create_router(const std::string& name) +{ + return kernel::actor::simcall([this, &name] { return pimpl_->create_router(name); }); } +kernel::routing::NetPoint* NetZone::get_netpoint() +{ + return pimpl_->get_netpoint(); +} + +kernel::resource::NetworkModelIntf* NetZone::get_network_model() const +{ + kernel::resource::NetworkModelIntf* model = pimpl_->get_network_model().get(); + return model; +} } // namespace s4u } // namespace simgrid