X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/1c6d9d13327f8dda85cc1215185196f3466766c1..a2efc66d85afec3b94c1d9ecf6d50b444b80b058:/src/surf/sg_platf.cpp diff --git a/src/surf/sg_platf.cpp b/src/surf/sg_platf.cpp index 33d727a123..4a237e7226 100644 --- a/src/surf/sg_platf.cpp +++ b/src/surf/sg_platf.cpp @@ -66,7 +66,8 @@ void sg_platf_new_host(sg_platf_host_cbarg_t args) std::unordered_map props; if (args->properties) { xbt_dict_cursor_t cursor=nullptr; - char *key,*data; + char *key; + char* data; xbt_dict_foreach (args->properties, cursor, key, data) props[key] = data; xbt_dict_free(&args->properties); @@ -115,7 +116,8 @@ simgrid::kernel::routing::NetPoint* sg_platf_new_router(const char* name, const return netpoint; } -void sg_platf_new_link(sg_platf_link_cbarg_t link){ +void sg_platf_new_link(LinkCreationArgs* link) +{ std::vector names; if (link->policy == SURF_LINK_FULLDUPLEX) { @@ -130,7 +132,8 @@ void sg_platf_new_link(sg_platf_link_cbarg_t link){ if (link->properties) { xbt_dict_cursor_t cursor = nullptr; - char *key, *data; + char* key; + char* data; xbt_dict_foreach (link->properties, cursor, key, data) l->setProperty(key, data); xbt_dict_free(&link->properties); @@ -154,7 +157,6 @@ void sg_platf_new_cluster(sg_platf_cluster_cbarg_t cluster) int rankId=0; - s_sg_platf_link_cbarg_t link; // What an inventive way of initializing the AS that I have as ancestor :-( s_sg_platf_AS_cbarg_t AS; @@ -177,12 +179,12 @@ void sg_platf_new_cluster(sg_platf_cluster_cbarg_t cluster) simgrid::kernel::routing::ClusterZone* current_as = static_cast(routing_get_current()); current_as->parse_specific_arguments(cluster); - if(cluster->loopback_bw!=0 || cluster->loopback_lat!=0){ + if(cluster->loopback_bw > 0 || cluster->loopback_lat > 0){ current_as->linkCountPerNode_++; current_as->hasLoopback_ = 1; } - if(cluster->limiter_link!=0){ + if(cluster->limiter_link > 0){ current_as->linkCountPerNode_++; current_as->hasLimiter_ = 1; } @@ -191,14 +193,15 @@ void sg_platf_new_cluster(sg_platf_cluster_cbarg_t cluster) char * host_id = bprintf("%s%d%s", cluster->prefix, i, cluster->suffix); char * link_id = bprintf("%s_link_%d", cluster->id, i); - XBT_DEBUG("", host_id, cluster->speed); + XBT_DEBUG("", host_id, cluster->speeds.front()); s_sg_platf_host_cbarg_t host; memset(&host, 0, sizeof(host)); host.id = host_id; if ((cluster->properties != nullptr) && (!xbt_dict_is_empty(cluster->properties))) { xbt_dict_cursor_t cursor=nullptr; - char *key,*data; + char *key; + char* data; host.properties = xbt_dict_new_homogeneous(free); xbt_dict_foreach(cluster->properties,cursor,key,data) { @@ -206,7 +209,7 @@ void sg_platf_new_cluster(sg_platf_cluster_cbarg_t cluster) } } - host.speed_per_pstate.push_back(cluster->speed); + host.speed_per_pstate = cluster->speeds; host.pstate = 0; host.core_amount = cluster->core_amount; host.coord = ""; @@ -224,11 +227,11 @@ void sg_platf_new_cluster(sg_platf_cluster_cbarg_t cluster) //add a loopback link simgrid::surf::LinkImpl* linkUp = nullptr; simgrid::surf::LinkImpl* linkDown = nullptr; - if(cluster->loopback_bw!=0 || cluster->loopback_lat!=0){ + if(cluster->loopback_bw > 0 || cluster->loopback_lat > 0){ char *tmp_link = bprintf("%s_loopback", link_id); XBT_DEBUG("", tmp_link, cluster->loopback_bw); - memset(&link, 0, sizeof(link)); + LinkCreationArgs link; link.id = tmp_link; link.bandwidth = cluster->loopback_bw; link.latency = cluster->loopback_lat; @@ -245,11 +248,11 @@ void sg_platf_new_cluster(sg_platf_cluster_cbarg_t cluster) //add a limiter link (shared link to account for maximal bandwidth of the node) linkUp = nullptr; linkDown = nullptr; - if(cluster->limiter_link!=0){ + if(cluster->limiter_link > 0){ char *tmp_link = bprintf("%s_limiter", link_id); XBT_DEBUG("", tmp_link, cluster->limiter_link); - memset(&link, 0, sizeof(link)); + LinkCreationArgs link; link.id = tmp_link; link.bandwidth = cluster->limiter_link; link.latency = 0; @@ -286,9 +289,9 @@ void sg_platf_new_cluster(sg_platf_cluster_cbarg_t cluster) } //Make the backbone - if ((cluster->bb_bw != 0) || (cluster->bb_lat != 0)) { + if ((cluster->bb_bw > 0) || (cluster->bb_lat > 0)) { - memset(&link, 0, sizeof(link)); + LinkCreationArgs link; link.id = std::string(cluster->id)+ "_backbone"; link.bandwidth = cluster->bb_bw; link.latency = cluster->bb_lat; @@ -331,8 +334,7 @@ void sg_platf_new_cabinet(sg_platf_cabinet_cbarg_t cabinet) host.speed_per_pstate.push_back(cabinet->speed); sg_platf_new_host(&host); - s_sg_platf_link_cbarg_t link; - memset(&link, 0, sizeof(link)); + LinkCreationArgs link; link.policy = SURF_LINK_FULLDUPLEX; link.latency = cabinet->lat; link.bandwidth = cabinet->bw; @@ -390,7 +392,8 @@ void sg_platf_new_storage(sg_platf_storage_cbarg_t storage) if (storage->properties) { xbt_dict_cursor_t cursor = nullptr; - char *key, *data; + char *key; + char* data; xbt_dict_foreach (storage->properties, cursor, key, data) s->setProperty(key, data); xbt_dict_free(&storage->properties);