X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/d7137248837c462e9a20c5640f2c74541faa7ef5..2558c8c0eb206ff353cb88672f5a90cd0e2562d3:/src/kernel/routing/FatTreeZone.cpp diff --git a/src/kernel/routing/FatTreeZone.cpp b/src/kernel/routing/FatTreeZone.cpp index 6101508561..ae1556c658 100644 --- a/src/kernel/routing/FatTreeZone.cpp +++ b/src/kernel/routing/FatTreeZone.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2014-2018. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2014-2019. 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. */ @@ -22,7 +22,8 @@ namespace simgrid { namespace kernel { namespace routing { -FatTreeZone::FatTreeZone(NetZone* father, std::string name) : ClusterZone(father, name) +FatTreeZone::FatTreeZone(NetZoneImpl* father, const std::string& name, resource::NetworkModel* netmodel) + : ClusterZone(father, name, netmodel) { XBT_DEBUG("Creating a new fat tree."); } @@ -37,7 +38,7 @@ FatTreeZone::~FatTreeZone() } } -bool FatTreeZone::isInSubTree(FatTreeNode* root, FatTreeNode* node) +bool FatTreeZone::is_in_sub_tree(FatTreeNode* root, FatTreeNode* node) { XBT_DEBUG("Is %d(%u,%u) in the sub tree of %d(%u,%u) ?", node->id, node->level, node->position, root->id, root->level, root->position); @@ -89,7 +90,7 @@ void FatTreeZone::get_local_route(NetPoint* src, NetPoint* dst, RouteCreationArg FatTreeNode* currentNode = source; // up part - while (not isInSubTree(currentNode, destination)) { + while (not is_in_sub_tree(currentNode, destination)) { int d = destination->position; // as in d-mod-k for (unsigned int i = 0; i < currentNode->level; i++) @@ -135,7 +136,7 @@ void FatTreeZone::seal() if (this->levels_ == 0) { return; } - this->generateSwitches(); + this->generate_switches(); if (XBT_LOG_ISENABLED(surf_route_fat_tree, xbt_log_priority_debug)) { std::stringstream msgBuffer; @@ -155,13 +156,13 @@ void FatTreeZone::seal() XBT_DEBUG("%s", msgBuffer.str().c_str()); } - this->generateLabels(); + this->generate_labels(); unsigned int k = 0; // Nodes are totally ordered, by level and then by position, in this->nodes for (unsigned int i = 0; i < this->levels_; i++) { for (unsigned int j = 0; j < this->nodes_by_level_[i]; j++) { - this->connectNodeToParents(this->nodes_[k]); + this->connect_node_to_parents(this->nodes_[k]); k++; } } @@ -176,15 +177,15 @@ void FatTreeZone::seal() } } -int FatTreeZone::connectNodeToParents(FatTreeNode* node) +int FatTreeZone::connect_node_to_parents(FatTreeNode* node) { std::vector::iterator currentParentNode = this->nodes_.begin(); int connectionsNumber = 0; const int level = node->level; XBT_DEBUG("We are connecting node %d(%u,%u) to his parents.", node->id, node->level, node->position); - currentParentNode += this->getLevelPosition(level + 1); + currentParentNode += this->get_level_position(level + 1); for (unsigned int i = 0; i < this->nodes_by_level_[level + 1]; i++) { - if (this->areRelated(*currentParentNode, node)) { + if (this->are_related(*currentParentNode, node)) { XBT_DEBUG("%d(%u,%u) and %d(%u,%u) are related," " with %u links between them.", node->id, node->level, node->position, (*currentParentNode)->id, (*currentParentNode)->level, @@ -200,7 +201,7 @@ int FatTreeZone::connectNodeToParents(FatTreeNode* node) return connectionsNumber; } -bool FatTreeZone::areRelated(FatTreeNode* parent, FatTreeNode* child) +bool FatTreeZone::are_related(FatTreeNode* parent, FatTreeNode* child) { std::stringstream msgBuffer; @@ -232,7 +233,7 @@ bool FatTreeZone::areRelated(FatTreeNode* parent, FatTreeNode* child) return true; } -void FatTreeZone::generateSwitches() +void FatTreeZone::generate_switches() { XBT_DEBUG("Generating switches."); this->nodes_by_level_.resize(this->levels_ + 1, 0); @@ -246,7 +247,6 @@ void FatTreeZone::generateSwitches() surf_parse_error(std::string("The number of provided nodes does not fit with the wanted topology.") + " Please check your platform description (We need " + std::to_string(this->nodes_by_level_[0]) + "nodes, we got " + std::to_string(this->nodes_.size())); - return; } for (unsigned int i = 0; i < this->levels_; i++) { @@ -277,7 +277,7 @@ void FatTreeZone::generateSwitches() } } -void FatTreeZone::generateLabels() +void FatTreeZone::generate_labels() { XBT_DEBUG("Generating labels."); // TODO : check if nodesByLevel and nodes are filled @@ -323,7 +323,7 @@ void FatTreeZone::generateLabels() } } -int FatTreeZone::getLevelPosition(const unsigned int level) +int FatTreeZone::get_level_position(const unsigned int level) { xbt_assert(level <= this->levels_, "The impossible did happen. Yet again."); int tempPosition = 0; @@ -450,7 +450,7 @@ FatTreeNode::FatTreeNode(ClusterCreationArgs* cluster, int id, int level, int po linkTemplate.policy = s4u::Link::SharingPolicy::SHARED; linkTemplate.id = "limiter_"+std::to_string(id); sg_platf_new_link(&linkTemplate); - this->limiter_link_ = resource::LinkImpl::by_name(linkTemplate.id); + this->limiter_link_ = s4u::Link::by_name(linkTemplate.id)->get_impl(); } if (cluster->loopback_bw || cluster->loopback_lat) { linkTemplate.bandwidth = cluster->loopback_bw; @@ -458,7 +458,7 @@ FatTreeNode::FatTreeNode(ClusterCreationArgs* cluster, int id, int level, int po linkTemplate.policy = s4u::Link::SharingPolicy::FATPIPE; linkTemplate.id = "loopback_"+ std::to_string(id); sg_platf_new_link(&linkTemplate); - this->loopback = resource::LinkImpl::by_name(linkTemplate.id); + this->loopback = s4u::Link::by_name(linkTemplate.id)->get_impl(); } } @@ -475,12 +475,10 @@ FatTreeLink::FatTreeLink(ClusterCreationArgs* cluster, FatTreeNode* downNode, Fa sg_platf_new_link(&linkTemplate); if (cluster->sharing_policy == s4u::Link::SharingPolicy::SPLITDUPLEX) { - std::string tmpID = std::string(linkTemplate.id) + "_UP"; - this->up_link_ = resource::LinkImpl::by_name(tmpID); // check link? - tmpID = std::string(linkTemplate.id) + "_DOWN"; - this->down_link_ = resource::LinkImpl::by_name(tmpID); // check link ? + this->up_link_ = s4u::Link::by_name(linkTemplate.id + "_UP")->get_impl(); // check link? + this->down_link_ = s4u::Link::by_name(linkTemplate.id + "_DOWN")->get_impl(); // check link ? } else { - this->up_link_ = resource::LinkImpl::by_name(linkTemplate.id); + this->up_link_ = s4u::Link::by_name(linkTemplate.id)->get_impl(); this->down_link_ = this->up_link_; } uniqueId++;