X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/e26a153e0ece22e44a1e05fca169114d935960df..a950964746f6cebea710308f7dba68bdfb424694:/src/kernel/routing/FatTreeZone.cpp diff --git a/src/kernel/routing/FatTreeZone.cpp b/src/kernel/routing/FatTreeZone.cpp index c01781511a..8a551eac5f 100644 --- a/src/kernel/routing/FatTreeZone.cpp +++ b/src/kernel/routing/FatTreeZone.cpp @@ -22,8 +22,8 @@ namespace simgrid { namespace kernel { namespace routing { -FatTreeZone::FatTreeZone(NetZoneImpl* father, std::string name, resource::NetworkModel* netmodel) - : ClusterZone(father, std::move(name), netmodel) +FatTreeZone::FatTreeZone(NetZoneImpl* father, const std::string& name, resource::NetworkModel* netmodel) + : ClusterZone(father, name, netmodel) { XBT_DEBUG("Creating a new fat tree."); } @@ -291,7 +291,6 @@ void FatTreeZone::generate_labels() } for (unsigned int j = 0; j < this->nodes_by_level_[i]; j++) { - if (XBT_LOG_ISENABLED(surf_route_fat_tree, xbt_log_priority_debug)) { std::stringstream msgBuffer; @@ -363,55 +362,55 @@ void FatTreeZone::parse_specific_arguments(ClusterCreationArgs* cluster) std::vector parameters; std::vector tmp; boost::split(parameters, cluster->topo_parameters, boost::is_any_of(";")); - const std::string error_msg {"Fat trees are defined by the levels number and 3 vectors, see the documentation for more information"}; // TODO : we have to check for zeros and negative numbers, or it might crash - if (parameters.size() != 4) { - surf_parse_error(error_msg); - } + surf_parse_assert( + parameters.size() == 4, + "Fat trees are defined by the levels number and 3 vectors, see the documentation for more information."); // The first parts of topo_parameters should be the levels number try { this->levels_ = std::stoi(parameters[0]); - } catch (std::invalid_argument& ia) { - throw std::invalid_argument(std::string("First parameter is not the amount of levels:") + parameters[0]); + } catch (const std::invalid_argument&) { + surf_parse_error(std::string("First parameter is not the amount of levels: ") + parameters[0]); } // Then, a l-sized vector standing for the children number by level boost::split(tmp, parameters[1], boost::is_any_of(",")); - if (tmp.size() != this->levels_) { - surf_parse_error(error_msg); - } + surf_parse_assert(tmp.size() == this->levels_, std::string("You specified ") + std::to_string(this->levels_) + + " levels but the child count vector (the first one) contains " + + std::to_string(tmp.size()) + " levels."); + for (size_t i = 0; i < tmp.size(); i++) { try { this->num_children_per_node_.push_back(std::stoi(tmp[i])); - } catch (std::invalid_argument& ia) { - throw std::invalid_argument(std::string("Invalid lower level node number:") + tmp[i]); + } catch (const std::invalid_argument&) { + surf_parse_error(std::string("Invalid child count: ") + tmp[i]); } } // Then, a l-sized vector standing for the parents number by level boost::split(tmp, parameters[2], boost::is_any_of(",")); - if (tmp.size() != this->levels_) { - surf_parse_error(error_msg); - } + surf_parse_assert(tmp.size() == this->levels_, std::string("You specified ") + std::to_string(this->levels_) + + " levels but the parent count vector (the second one) contains " + + std::to_string(tmp.size()) + " levels."); for (size_t i = 0; i < tmp.size(); i++) { try { this->num_parents_per_node_.push_back(std::stoi(tmp[i])); - } catch (std::invalid_argument& ia) { - throw std::invalid_argument(std::string("Invalid upper level node number:") + tmp[i]); + } catch (const std::invalid_argument&) { + surf_parse_error(std::string("Invalid parent count: ") + tmp[i]); } } // Finally, a l-sized vector standing for the ports number with the lower level boost::split(tmp, parameters[3], boost::is_any_of(",")); - if (tmp.size() != this->levels_) { - surf_parse_error(error_msg); - } + surf_parse_assert(tmp.size() == this->levels_, std::string("You specified ") + std::to_string(this->levels_) + + " levels but the port count vector (the third one) contains " + + std::to_string(tmp.size()) + " levels."); for (size_t i = 0; i < tmp.size(); i++) { try { this->num_port_lower_level_.push_back(std::stoi(tmp[i])); - } catch (std::invalid_argument& ia) { + } catch (const std::invalid_argument&) { throw std::invalid_argument(std::string("Invalid lower level port number:") + tmp[i]); } } @@ -445,7 +444,7 @@ FatTreeNode::FatTreeNode(ClusterCreationArgs* cluster, int id, int level, int po { LinkCreationArgs linkTemplate; if (cluster->limiter_link) { - linkTemplate.bandwidth = cluster->limiter_link; + linkTemplate.bandwidths.push_back(cluster->limiter_link); linkTemplate.latency = 0; linkTemplate.policy = s4u::Link::SharingPolicy::SHARED; linkTemplate.id = "limiter_"+std::to_string(id); @@ -453,7 +452,7 @@ FatTreeNode::FatTreeNode(ClusterCreationArgs* cluster, int id, int level, int po this->limiter_link_ = s4u::Link::by_name(linkTemplate.id)->get_impl(); } if (cluster->loopback_bw || cluster->loopback_lat) { - linkTemplate.bandwidth = cluster->loopback_bw; + linkTemplate.bandwidths.push_back(cluster->loopback_bw); linkTemplate.latency = cluster->loopback_lat; linkTemplate.policy = s4u::Link::SharingPolicy::FATPIPE; linkTemplate.id = "loopback_"+ std::to_string(id); @@ -467,7 +466,7 @@ FatTreeLink::FatTreeLink(ClusterCreationArgs* cluster, FatTreeNode* downNode, Fa { static int uniqueId = 0; LinkCreationArgs linkTemplate; - linkTemplate.bandwidth = cluster->bw; + linkTemplate.bandwidths.push_back(cluster->bw); linkTemplate.latency = cluster->lat; linkTemplate.policy = cluster->sharing_policy; // sthg to do with that ? linkTemplate.id = @@ -483,6 +482,6 @@ FatTreeLink::FatTreeLink(ClusterCreationArgs* cluster, FatTreeNode* downNode, Fa } uniqueId++; } -} -} -} // namespace +} // namespace routing +} // namespace kernel +} // namespace simgrid