X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/fc66c4b355619478b469a54fd5d3dfe77b9f4049..386fdb787b4d39af174e239965e51008bc9c330d:/src/surf/surf_routing_cluster_fat_tree.cpp diff --git a/src/surf/surf_routing_cluster_fat_tree.cpp b/src/surf/surf_routing_cluster_fat_tree.cpp index b32b6a6cbc..6527e15755 100644 --- a/src/surf/surf_routing_cluster_fat_tree.cpp +++ b/src/surf/surf_routing_cluster_fat_tree.cpp @@ -22,6 +22,9 @@ AsClusterFatTree::~AsClusterFatTree() { for (unsigned int i = 0 ; i < this->nodes.size() ; i++) { delete this->nodes[i]; } + for (unsigned int i = 0 ; i < this->links.size() ; i++) { + delete this->links[i]; + } } bool AsClusterFatTree::isInSubTree(FatTreeNode *root, FatTreeNode *node) { @@ -44,8 +47,8 @@ bool AsClusterFatTree::isInSubTree(FatTreeNode *root, FatTreeNode *node) { return true; } -void AsClusterFatTree::getRouteAndLatency(RoutingEdgePtr src, - RoutingEdgePtr dst, +void AsClusterFatTree::getRouteAndLatency(RoutingEdge *src, + RoutingEdge *dst, sg_platf_route_cbarg_t into, double *latency) { FatTreeNode *source, *destination, *currentNode; @@ -82,6 +85,7 @@ if (dst->getRcType() == SURF_NETWORK_ELEMENT_ROUTER || src->getRcType() == SURF_ if(latency) { *latency += source->loopback->getLatency(); } + return; } currentNode = source; @@ -284,9 +288,6 @@ void AsClusterFatTree::generateSwitches() { } - // If we have to many compute nodes, we ditch them - - // We create the switches int k = 0; for (unsigned int i = 0 ; i < this->levels ; i++) { @@ -415,7 +416,6 @@ void AsClusterFatTree::parse_specific_arguments(sg_platf_cluster_cbarg_t if (parameters.size() != 4){ surf_parse_error("Fat trees are defined by the levels number and 3 vectors" ", see the documentation for more informations"); - // Well, there's no doc, yet } // The first parts of topo_parameters should be the levels number @@ -492,7 +492,7 @@ void AsClusterFatTree::generateDotFile(const string& filename) const { FatTreeNode::FatTreeNode(sg_platf_cluster_cbarg_t cluster, int id, int level, int position) : id(id), level(level), position(position) { - s_sg_platf_link_cbarg_t linkTemplate; + s_sg_platf_link_cbarg_t linkTemplate = SG_PLATF_LINK_INITIALIZER; if(cluster->limiter_link) { memset(&linkTemplate, 0, sizeof(linkTemplate)); linkTemplate.bandwidth = cluster->limiter_link; @@ -501,9 +501,7 @@ FatTreeNode::FatTreeNode(sg_platf_cluster_cbarg_t cluster, int id, int level, linkTemplate.policy = SURF_LINK_SHARED; linkTemplate.id = bprintf("limiter_%d", id); sg_platf_new_link(&linkTemplate); - this->limiterLink = (NetworkLink*) xbt_lib_get_or_null(link_lib, - linkTemplate.id, - SURF_LINK_LEVEL); + this->limiterLink = Link::byName(linkTemplate.id); free((void*)linkTemplate.id); } if(cluster->loopback_bw || cluster->loopback_lat) { @@ -514,9 +512,7 @@ FatTreeNode::FatTreeNode(sg_platf_cluster_cbarg_t cluster, int id, int level, linkTemplate.policy = SURF_LINK_FATPIPE; linkTemplate.id = bprintf("loopback_%d", id); sg_platf_new_link(&linkTemplate); - this->loopback = (NetworkLink*) xbt_lib_get_or_null(link_lib, - linkTemplate.id, - SURF_LINK_LEVEL); + this->loopback = Link::byName(linkTemplate.id); free((void*)linkTemplate.id); } } @@ -526,7 +522,7 @@ FatTreeLink::FatTreeLink(sg_platf_cluster_cbarg_t cluster, FatTreeNode *upNode) : upNode(upNode), downNode(downNode) { static int uniqueId = 0; - s_sg_platf_link_cbarg_t linkTemplate; + s_sg_platf_link_cbarg_t linkTemplate = SG_PLATF_LINK_INITIALIZER; memset(&linkTemplate, 0, sizeof(linkTemplate)); linkTemplate.bandwidth = cluster->bw; linkTemplate.latency = cluster->lat; @@ -535,21 +531,18 @@ FatTreeLink::FatTreeLink(sg_platf_cluster_cbarg_t cluster, linkTemplate.id = bprintf("link_from_%d_to_%d_%d", downNode->id, upNode->id, uniqueId); sg_platf_new_link(&linkTemplate); - NetworkLink* link; + Link* link; std::string tmpID; if (cluster->sharing_policy == SURF_LINK_FULLDUPLEX) { tmpID = std::string(linkTemplate.id) + "_UP"; - link = (NetworkLink*) xbt_lib_get_or_null(link_lib, tmpID.c_str(), - SURF_LINK_LEVEL); + link = Link::byName(tmpID.c_str()); this->upLink = link; // check link? tmpID = std::string(linkTemplate.id) + "_DOWN"; - link = (NetworkLink*) xbt_lib_get_or_null(link_lib, tmpID.c_str(), - SURF_LINK_LEVEL); + link = Link::byName(tmpID.c_str()); this->downLink = link; // check link ? } else { - link = (NetworkLink*) xbt_lib_get_or_null(link_lib, linkTemplate.id, - SURF_LINK_LEVEL); + link = Link::byName(linkTemplate.id); this->upLink = link; this->downLink = link; }