X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/0438cb0afe03a5f104af019df44f52aec27d2458..3203ed1f4fb6f4617e94d5351661ba07e8b8f833:/teshsuite/simdag/platforms/flatifier.c diff --git a/teshsuite/simdag/platforms/flatifier.c b/teshsuite/simdag/platforms/flatifier.c index de0bd15007..3115c3f701 100644 --- a/teshsuite/simdag/platforms/flatifier.c +++ b/teshsuite/simdag/platforms/flatifier.c @@ -1,4 +1,4 @@ -/* Copyright (c) 2008, 2009, 2010. The SimGrid Team. +/* Copyright (c) 2008-2015. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -15,12 +15,16 @@ #include -#include "simdag/simdag.h" +#include "simgrid/simdag.h" #include "xbt/log.h" #include "xbt/dict.h" #include "xbt/ex.h" +#include "xbt/xbt_os_time.h" #include "surf/surf.h" -#include "surf/surf_private.h" +#include "src/surf/surf_private.h" + +static const char link_ctn_v2[] = "link:ctn"; +static const char link_ctn_v3[] = "link_ctn"; XBT_LOG_NEW_DEFAULT_CATEGORY(flatifier, "Logging specific to this platform parsing tool"); @@ -43,11 +47,50 @@ static int name_compare_links(const void *n1, const void *n2) return strcmp(name1, name2); } +static int parse_cmdline(int *timings, int *downgrade, char **platformFile, int argc, char **argv) +{ + int wrong_option = 0; + int i; + for (i = 1; i < argc; i++) { + if (strlen(argv[i]) > 1 && argv[i][0] == '-' && argv[i][1] == '-') { + if (!strcmp(argv[i], "--timings")) { + *timings = 1; + } else { + if (!strcmp(argv[i], "--downgrade")) { + *downgrade = 1; + } else { + wrong_option = 1; + break; + } + } + } else { + *platformFile = argv[i]; + } + } + return wrong_option; +} + +static void create_environment(xbt_os_timer_t parse_time, const char *platformFile) +{ + xbt_ex_t e; + TRY { + xbt_os_cputimer_start(parse_time); + SD_create_environment(platformFile); + xbt_os_cputimer_stop(parse_time); + } + CATCH(e) { + xbt_die("Error while loading %s: %s", platformFile, e.msg); + } +} + int main(int argc, char **argv) { char *platformFile = NULL; int totalHosts, totalLinks; int timings=0; + int downgrade = 0; + int version = 3; + const char *link_ctn = link_ctn_v3; unsigned int i; xbt_dict_t props = NULL; xbt_dict_cursor_t cursor = NULL; @@ -56,40 +99,42 @@ int main(int argc, char **argv) char *src,*dst,*key,*data; sg_routing_edge_t value1; sg_routing_edge_t value2; - xbt_ex_t e; const SD_workstation_t *hosts; const SD_link_t *links; xbt_os_timer_t parse_time = xbt_os_timer_new(); +#ifdef _XBT_WIN32 + setbuf(stderr, NULL); + setbuf(stdout, NULL); +#else setvbuf(stdout, NULL, _IOLBF, 0); +#endif SD_init(&argc, argv); - platformFile = argv[1]; - if (!strcmp(platformFile,"--timings")) { - platformFile=argv[2]; - timings=1; - } - - XBT_DEBUG("%s", platformFile); - TRY { - xbt_os_timer_start(parse_time); - SD_create_environment(platformFile); - xbt_os_timer_stop(parse_time); + if (parse_cmdline(&timings, &downgrade, &platformFile, argc, argv) || !platformFile) { + xbt_die("Invalid command line arguments: expected [--timings|--downgrade] platformFile"); } - CATCH(e) { - xbt_die("Error while loading %s: %s",platformFile,e.msg); + + XBT_DEBUG("%d,%d,%s", timings, downgrade, platformFile); + + if (downgrade) { + version = 2; + link_ctn = link_ctn_v2; } + create_environment(parse_time, platformFile); + if (timings) { XBT_INFO("Parsing time: %fs (%d hosts, %d links)", xbt_os_timer_elapsed(parse_time),SD_workstation_get_number(),SD_link_get_number()); } else { printf("\n"); printf("\n"); - printf("\n"); - printf("\n"); + printf("\n", version); + if (!downgrade) + printf("\n"); // Hosts totalHosts = SD_workstation_get_number(); @@ -102,6 +147,9 @@ int main(int argc, char **argv) SD_workstation_get_name(hosts[i]), SD_workstation_get_power(hosts[i])); props = SD_workstation_get_properties(hosts[i]); + if (SD_workstation_get_cores(hosts[i])>1) { + printf(" core=\"%d\"", SD_workstation_get_cores(hosts[i])); + } if (props && !xbt_dict_is_empty(props)) { printf(">\n"); xbt_dict_foreach(props, cursor, key, data) { @@ -115,8 +163,8 @@ int main(int argc, char **argv) // Routers xbt_lib_foreach(as_router_lib, cursor_src, key, value1) { - if(((sg_routing_edge_t)xbt_lib_get_or_null(as_router_lib, key, - ROUTING_ASR_LEVEL))->rc_type == SURF_NETWORK_ELEMENT_ROUTER) + if(surf_routing_edge_get_rc_type(xbt_lib_get_or_null(as_router_lib, key, + ROUTING_ASR_LEVEL)) == SURF_NETWORK_ELEMENT_ROUTER) { printf(" \n",key); } @@ -135,7 +183,7 @@ int main(int argc, char **argv) SD_link_get_name(links[i]), SD_link_get_current_bandwidth(links[i]), SD_link_get_current_latency(links[i])); - if (SD_link_get_sharing_policy(links[i]) == SD_LINK_SHARED) { + if (SD_link_is_shared(links[i])) { printf("/>\n"); } else { printf(" sharing_policy=\"FATPIPE\"/>\n"); @@ -145,21 +193,21 @@ int main(int argc, char **argv) xbt_lib_foreach(host_lib, cursor_src, src, value1) // Routes from host { - value1 = xbt_lib_get_or_null(host_lib,src,ROUTING_HOST_LEVEL); + value1 = sg_host_edge(sg_host_by_name(src)); xbt_lib_foreach(host_lib, cursor_dst, dst, value2) //to host { printf(" \n " ,src ,dst); xbt_dynar_t route=NULL; - value2 = xbt_lib_get_or_null(host_lib,dst,ROUTING_HOST_LEVEL); + value2 = sg_host_edge(sg_host_by_name(dst)); routing_get_route_and_latency(value1,value2,&route,NULL); for(i=0;iname); - printf("",link_name); + char *link_name = xbt_strdup(surf_resource_name(link)); + printf("<%s id=\"%s\"/>",link_ctn,link_name); free(link_name); } printf("\n \n"); @@ -177,8 +225,8 @@ int main(int argc, char **argv) { void *link = xbt_dynar_get_as(route,i,void *); - char *link_name = xbt_strdup(((surf_resource_t)link)->name); - printf("",link_name); + char *link_name = xbt_strdup(surf_resource_name(link)); + printf("<%s id=\"%s\"/>",link_ctn,link_name); free(link_name); } printf("\n \n"); @@ -203,8 +251,8 @@ int main(int argc, char **argv) { void *link = xbt_dynar_get_as(route,i,void *); - char *link_name = xbt_strdup(((surf_resource_t)link)->name); - printf("",link_name); + char *link_name = xbt_strdup(surf_resource_name(link)); + printf("<%s id=\"%s\"/>",link_ctn,link_name); free(link_name); } printf("\n \n"); @@ -215,14 +263,14 @@ int main(int argc, char **argv) printf(" \n " ,src, dst); xbt_dynar_t route=NULL; - value2 = xbt_lib_get_or_null(host_lib,dst,ROUTING_HOST_LEVEL); + value2 = sg_host_edge(sg_host_by_name(dst)); routing_get_route_and_latency((sg_routing_edge_t)value1,(sg_routing_edge_t)value2,&route, NULL); for(i=0;iname); - printf("",link_name); + char *link_name = xbt_strdup(surf_resource_name(link)); + printf("<%s id=\"%s\"/>",link_ctn,link_name); free(link_name); } printf("\n \n"); @@ -230,10 +278,12 @@ int main(int argc, char **argv) } } - printf("\n"); + if (!downgrade) + printf("\n"); printf("\n"); } SD_exit(); + xbt_os_timer_free(parse_time); return 0; }