src/surf/surf_routing.c

   1 /* Copyright (c) 2009, 2010, 2011. The SimGrid Team.
   2  * All rights reserved.                                                     */
   3
   4 /* This program is free software; you can redistribute it and/or modify it
   5  * under the terms of the license (GNU LGPL) which comes with this package. */
   6
   7 #include <pcre.h>               /* regular expression library */
   8
   9 #include "simgrid/platf_interface.h"    // platform creation API internal interface
  10
  11 #include "surf_routing_private.h"
  12 #include "surf/surf_routing.h"
  13 #include "surf/surfxml_parse_values.h"
  14
  15 xbt_lib_t host_lib;
  16 int ROUTING_HOST_LEVEL;         //Routing level
  17 int SURF_CPU_LEVEL;             //Surf cpu level
  18 int SURF_WKS_LEVEL;             //Surf workstation level
  19 int SIMIX_HOST_LEVEL;           //Simix level
  20 int MSG_HOST_LEVEL;             //Msg level
  21 int SD_HOST_LEVEL;              //Simdag level
  22 int COORD_HOST_LEVEL;           //Coordinates level
  23 int NS3_HOST_LEVEL;             //host node for ns3
  24
  25 xbt_lib_t link_lib;
  26 int SD_LINK_LEVEL;              //Simdag level
  27 int SURF_LINK_LEVEL;            //Surf level
  28 int NS3_LINK_LEVEL;             //link for ns3
  29
  30 xbt_lib_t as_router_lib;
  31 int ROUTING_ASR_LEVEL;          //Routing level
  32 int COORD_ASR_LEVEL;            //Coordinates level
  33 int NS3_ASR_LEVEL;              //host node for ns3
  34
  35 static xbt_dict_t patterns = NULL;
  36 static xbt_dict_t random_value = NULL;
  37
  38 /* Global vars */
  39 routing_global_t global_routing = NULL;
  40 routing_component_t current_routing = NULL;
  41 model_type_t current_routing_model = NULL;
  42
  43 /* global parse functions */
  44 xbt_dynar_t link_list = NULL;   /* temporary store of current list link of a route */
  45 static const char *src = NULL;  /* temporary store the source name of a route */
  46 static const char *dst = NULL;  /* temporary store the destination name of a route */
  47 static char *gw_src = NULL;     /* temporary store the gateway source name of a route */
  48 static char *gw_dst = NULL;     /* temporary store the gateway destination name of a route */
  49
  50 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(surf_route, surf, "Routing part of surf");
  51
  52 static void routing_parse_peer(sg_platf_peer_cbarg_t peer);     /* peer bypass */
  53 static void routing_parse_Srandom(void);        /* random bypass */
  54
  55 static char *replace_random_parameter(char *chaine);
  56 static void routing_parse_postparse(void);
  57
  58 /* this lines are only for replace use like index in the model table */
  59 typedef enum {
  60   SURF_MODEL_FULL = 0,
  61   SURF_MODEL_FLOYD,
  62   SURF_MODEL_DIJKSTRA,
  63   SURF_MODEL_DIJKSTRACACHE,
  64   SURF_MODEL_NONE,
  65   SURF_MODEL_RULEBASED,
  66   SURF_MODEL_VIVALDI,
  67   SURF_MODEL_CLUSTER
  68 } e_routing_types;
  69
  70 struct s_model_type routing_models[] = {
  71   {"Full",
  72    "Full routing data (fast, large memory requirements, fully expressive)",
  73    model_full_create, NULL,NULL, model_full_end},
  74   {"Floyd",
  75    "Floyd routing data (slow initialization, fast lookup, lesser memory requirements, shortest path routing only)",
  76    model_floyd_create, NULL,NULL, model_floyd_end},
  77   {"Dijkstra",
  78    "Dijkstra routing data (fast initialization, slow lookup, small memory requirements, shortest path routing only)",
  79    model_dijkstra_create, NULL,NULL, model_dijkstra_both_end},
  80   {"DijkstraCache",
  81    "Dijkstra routing data (fast initialization, fast lookup, small memory requirements, shortest path routing only)",
  82    model_dijkstracache_create, NULL,NULL, model_dijkstra_both_end},
  83   {"none", "No routing (usable with Constant network only)",
  84    model_none_create, NULL, NULL, NULL},
  85   {"RuleBased", "Rule-Based routing data (...)",
  86    model_rulebased_create, NULL, NULL, NULL},
  87   {"Vivaldi", "Vivaldi routing",
  88    model_vivaldi_create, NULL, NULL, NULL},
  89   {"Cluster", "Cluster routing",
  90    model_cluster_create, NULL, NULL, NULL},
  91   {NULL, NULL, NULL, NULL, NULL, NULL}
  92 };
  93
  94 /**
  95  * \brief Add a "host" to the network element list
  96  */
  97 static void parse_S_host(sg_platf_host_cbarg_t host)
  98 {
  99   network_element_info_t info = NULL;
 100   if (current_routing->hierarchy == SURF_ROUTING_NULL)
 101     current_routing->hierarchy = SURF_ROUTING_BASE;
 102   xbt_assert(!xbt_lib_get_or_null(host_lib, host->id, ROUTING_HOST_LEVEL),
 103              "Reading a host, processing unit \"%s\" already exists", host->id);
 104   xbt_assert(current_routing->set_processing_unit,
 105              "no defined method \"set_processing_unit\" in \"%s\"",
 106              current_routing->name);
 107   (*(current_routing->set_processing_unit)) (current_routing, host->id);
 108   info = xbt_new0(s_network_element_info_t, 1);
 109   info->rc_component = current_routing;
 110   info->rc_type = SURF_NETWORK_ELEMENT_HOST;
 111   xbt_lib_set(host_lib, host->id, ROUTING_HOST_LEVEL, (void *) info);
 112   if (host->coord && strcmp(host->coord, "")) {
 113     if (!COORD_HOST_LEVEL)
 114       xbt_die
 115           ("To use coordinates, you must set configuration 'coordinates' to 'yes'");
 116     xbt_dynar_t ctn = xbt_str_split_str(host->coord, " ");
 117     xbt_dynar_shrink(ctn, 0);
 118     xbt_lib_set(host_lib, host->id, COORD_HOST_LEVEL, (void *) ctn);
 119   }
 120 }
 121
 122 /**
 123  * \brief Add a "router" to the network element list
 124  */
 125 static void parse_S_router(sg_platf_router_cbarg_t router)
 126 {
 127   network_element_info_t info = NULL;
 128   if (current_routing->hierarchy == SURF_ROUTING_NULL)
 129     current_routing->hierarchy = SURF_ROUTING_BASE;
 130   xbt_assert(!xbt_lib_get_or_null(as_router_lib, router->id, ROUTING_ASR_LEVEL),
 131              "Reading a router, processing unit \"%s\" already exists",
 132              router->id);
 133   xbt_assert(current_routing->set_processing_unit,
 134              "no defined method \"set_processing_unit\" in \"%s\"",
 135              current_routing->name);
 136   (*(current_routing->set_processing_unit)) (current_routing, router->id);
 137   info = xbt_new0(s_network_element_info_t, 1);
 138   info->rc_component = current_routing;
 139   info->rc_type = SURF_NETWORK_ELEMENT_ROUTER;
 140
 141   xbt_lib_set(as_router_lib, router->id, ROUTING_ASR_LEVEL, (void *) info);
 142   if (strcmp(router->coord, "")) {
 143     if (!COORD_ASR_LEVEL)
 144       xbt_die
 145           ("To use coordinates, you must set configuration 'coordinates' to 'yes'");
 146     xbt_dynar_t ctn = xbt_str_split_str(router->coord, " ");
 147     xbt_dynar_shrink(ctn, 0);
 148     xbt_lib_set(as_router_lib, router->id, COORD_ASR_LEVEL, (void *) ctn);
 149   }
 150 }
 151
 152
 153 /**
 154  * \brief Set the end points for a route
 155  */
 156 static void routing_parse_S_route(void)
 157 {
 158   if (src != NULL && dst != NULL && link_list != NULL)
 159     THROWF(arg_error, 0, "Route between %s to %s can not be defined",
 160            A_surfxml_route_src, A_surfxml_route_dst);
 161   src = A_surfxml_route_src;
 162   dst = A_surfxml_route_dst;
 163   xbt_assert(strlen(src) > 0 || strlen(dst) > 0,
 164              "Some limits are null in the route between \"%s\" and \"%s\"",
 165              src, dst);
 166   link_list = xbt_dynar_new(sizeof(char *), &xbt_free_ref);
 167 }
 168
 169 /**
 170  * \brief Set the end points and gateways for a ASroute
 171  */
 172 static void routing_parse_S_ASroute(void)
 173 {
 174   if (src != NULL && dst != NULL && link_list != NULL)
 175     THROWF(arg_error, 0, "Route between %s to %s can not be defined",
 176            A_surfxml_ASroute_src, A_surfxml_ASroute_dst);
 177   src = A_surfxml_ASroute_src;
 178   dst = A_surfxml_ASroute_dst;
 179   gw_src = A_surfxml_ASroute_gw_src;
 180   gw_dst = A_surfxml_ASroute_gw_dst;
 181   xbt_assert(strlen(src) > 0 || strlen(dst) > 0 || strlen(gw_src) > 0
 182              || strlen(gw_dst) > 0,
 183              "Some limits are null in the route between \"%s\" and \"%s\"",
 184              src, dst);
 185   link_list = xbt_dynar_new(sizeof(char *), &xbt_free_ref);
 186 }
 187
 188 /**
 189  * \brief Set the end points for a bypassRoute
 190  */
 191 static void routing_parse_S_bypassRoute(void)
 192 {
 193   if (src != NULL && dst != NULL && link_list != NULL)
 194     THROWF(arg_error, 0,
 195            "Bypass Route between %s to %s can not be defined",
 196            A_surfxml_bypassRoute_src, A_surfxml_bypassRoute_dst);
 197   src = A_surfxml_bypassRoute_src;
 198   dst = A_surfxml_bypassRoute_dst;
 199   gw_src = A_surfxml_bypassRoute_gw_src;
 200   gw_dst = A_surfxml_bypassRoute_gw_dst;
 201   xbt_assert(strlen(src) > 0 || strlen(dst) > 0 || strlen(gw_src) > 0
 202              || strlen(gw_dst) > 0,
 203              "Some limits are null in the route between \"%s\" and \"%s\"",
 204              src, dst);
 205   link_list = xbt_dynar_new(sizeof(char *), &xbt_free_ref);
 206 }
 207
 208 /**
 209  * \brief Set a new link on the actual list of link for a route or ASroute from XML
 210  */
 211
 212 static void routing_parse_link_ctn(void)
 213 {
 214   char *link_id;
 215   switch (A_surfxml_link_ctn_direction) {
 216   case AU_surfxml_link_ctn_direction:
 217   case A_surfxml_link_ctn_direction_NONE:
 218     link_id = xbt_strdup(A_surfxml_link_ctn_id);
 219     break;
 220   case A_surfxml_link_ctn_direction_UP:
 221     link_id = bprintf("%s_UP", A_surfxml_link_ctn_id);
 222     break;
 223   case A_surfxml_link_ctn_direction_DOWN:
 224     link_id = bprintf("%s_DOWN", A_surfxml_link_ctn_id);
 225     break;
 226   }
 227   xbt_dynar_push(link_list, &link_id);
 228 }
 229
 230 /**
 231  * \brief Store the route by calling the set_route function of the current routing component
 232  */
 233 static void routing_parse_E_route(void)
 234 {
 235   name_route_extended_t route = xbt_new0(s_name_route_extended_t, 1);
 236   route->generic_route.link_list = link_list;
 237   xbt_assert(current_routing->set_route,
 238              "no defined method \"set_route\" in \"%s\"",
 239              current_routing->name);
 240   (*(current_routing->set_route)) (current_routing, src, dst, route);
 241   link_list = NULL;
 242   src = NULL;
 243   dst = NULL;
 244 }
 245
 246 /**
 247  * \brief Store the ASroute by calling the set_ASroute function of the current routing component
 248  */
 249 static void routing_parse_E_ASroute(void)
 250 {
 251   name_route_extended_t e_route = xbt_new0(s_name_route_extended_t, 1);
 252   e_route->generic_route.link_list = link_list;
 253   e_route->src_gateway = xbt_strdup(gw_src);
 254   e_route->dst_gateway = xbt_strdup(gw_dst);
 255   xbt_assert(current_routing->set_ASroute,
 256              "no defined method \"set_ASroute\" in \"%s\"",
 257              current_routing->name);
 258   (*(current_routing->set_ASroute)) (current_routing, src, dst, e_route);
 259   link_list = NULL;
 260   src = NULL;
 261   dst = NULL;
 262   gw_src = NULL;
 263   gw_dst = NULL;
 264 }
 265
 266 /**
 267  * \brief Store the bypass route by calling the set_bypassroute function of the current routing component
 268  */
 269 static void routing_parse_E_bypassRoute(void)
 270 {
 271   route_extended_t e_route = xbt_new0(s_route_extended_t, 1);
 272   e_route->generic_route.link_list = link_list;
 273   e_route->src_gateway = xbt_strdup(gw_src);
 274   e_route->dst_gateway = xbt_strdup(gw_dst);
 275   xbt_assert(current_routing->set_bypassroute,
 276              "Bypassing mechanism not implemented by routing '%s'",
 277              current_routing->name);
 278   (*(current_routing->set_bypassroute)) (current_routing, src, dst, e_route);
 279   link_list = NULL;
 280   src = NULL;
 281   dst = NULL;
 282   gw_src = NULL;
 283   gw_dst = NULL;
 284 }
 285
 286 /**
 287  * \brief Make a new routing component to the platform
 288  *
 289  * Add a new autonomous system to the platform. Any elements (such as host,
 290  * router or sub-AS) added after this call and before the corresponding call
 291  * to sg_platf_new_AS_close() will be added to this AS.
 292  *
 293  * Once this function was called, the configuration concerning the used
 294  * models cannot be changed anymore.
 295  *
 296  * @param AS_id name of this autonomous system. Must be unique in the platform
 297  * @param wanted_routing_type one of Full, Floyd, Dijkstra or similar. Full list in the variable routing_models, in src/surf/surf_routing.c
 298  */
 299 void routing_AS_open(const char *AS_id, const char *wanted_routing_type)
 300 {
 301   routing_component_t new_routing;
 302   model_type_t model = NULL;
 303   int cpt;
 304
 305   surf_parse_models_setup();    /* ensure that the models are created after the last <config> tag and before the first <AS>-like */
 306
 307   /* search the routing model */
 308   for (cpt = 0; routing_models[cpt].name; cpt++)
 309     if (!strcmp(wanted_routing_type, routing_models[cpt].name))
 310       model = &routing_models[cpt];
 311   /* if its not exist, error */
 312   if (model == NULL) {
 313     fprintf(stderr, "Routing model %s not found. Existing models:\n",
 314             wanted_routing_type);
 315     for (cpt = 0; routing_models[cpt].name; cpt++)
 316       fprintf(stderr, "   %s: %s\n", routing_models[cpt].name,
 317               routing_models[cpt].desc);
 318     xbt_die(NULL);
 319   }
 320
 321   /* make a new routing component */
 322   new_routing = (routing_component_t) (*(model->create)) ();
 323   new_routing->routing = model;
 324   new_routing->hierarchy = SURF_ROUTING_NULL;
 325   new_routing->name = xbt_strdup(AS_id);
 326   new_routing->routing_sons = xbt_dict_new();
 327
 328   if (current_routing == NULL && global_routing->root == NULL) {
 329
 330     /* it is the first one */
 331     new_routing->routing_father = NULL;
 332     global_routing->root = new_routing;
 333
 334   } else if (current_routing != NULL && global_routing->root != NULL) {
 335
 336     xbt_assert(!xbt_dict_get_or_null
 337                (current_routing->routing_sons, AS_id),
 338                "The AS \"%s\" already exists", AS_id);
 339     /* it is a part of the tree */
 340     new_routing->routing_father = current_routing;
 341     /* set the father behavior */
 342     if (current_routing->hierarchy == SURF_ROUTING_NULL)
 343       current_routing->hierarchy = SURF_ROUTING_RECURSIVE;
 344     /* add to the sons dictionary */
 345     xbt_dict_set(current_routing->routing_sons, AS_id,
 346                  (void *) new_routing, NULL);
 347     /* add to the father element list */
 348     (*(current_routing->set_autonomous_system)) (current_routing, AS_id);
 349     /* unload the prev parse rules */
 350     if (current_routing->routing->unload)
 351       (*(current_routing->routing->unload)) ();
 352
 353   } else {
 354     THROWF(arg_error, 0, "All defined components must be belong to a AS");
 355   }
 356   /* set the new parse rules */
 357   if (new_routing->routing->load)
 358     (*(new_routing->routing->load)) ();
 359   /* set the new current component of the tree */
 360   current_routing = new_routing;
 361 }
 362
 363 /**
 364  * \brief Specify that the current description of AS is finished
 365  *
 366  * Once you've declared all the content of your AS, you have to close
 367  * it with this call. Your AS is not usable until you call this function.
 368  *
 369  * @fixme: this call is not as robust as wanted: bad things WILL happen
 370  * if you call it twice for the same AS, or if you forget calling it, or
 371  * even if you add stuff to a closed AS
 372  *
 373  */
 374 void routing_AS_close()
 375 {
 376
 377   if (current_routing == NULL) {
 378     THROWF(arg_error, 0, "Close an AS, but none was under construction");
 379   } else {
 380     network_element_info_t info = NULL;
 381     xbt_assert(!xbt_lib_get_or_null
 382                (as_router_lib, current_routing->name, ROUTING_ASR_LEVEL),
 383                "The AS \"%s\" already exists", current_routing->name);
 384     info = xbt_new0(s_network_element_info_t, 1);
 385     info->rc_component = current_routing->routing_father;
 386     info->rc_type = SURF_NETWORK_ELEMENT_AS;
 387     xbt_lib_set(as_router_lib, current_routing->name, ROUTING_ASR_LEVEL,
 388                 (void *) info);
 389
 390     if (current_routing->routing->unload)
 391       (*(current_routing->routing->unload)) ();
 392     if (current_routing->routing->end)
 393       (*(current_routing->routing->end)) ();
 394     current_routing = current_routing->routing_father;
 395     if (current_routing != NULL && current_routing->routing->load != NULL)
 396       (*(current_routing->routing->load)) ();
 397   }
 398 }
 399
 400 /* Aux Business methods */
 401
 402 /**
 403  * \brief Get the AS name of the element
 404  *
 405  * \param name the host name
 406  *
 407  */
 408 static char *elements_As_name(const char *name)
 409 {
 410   routing_component_t as_comp;
 411
 412   /* (1) find the as where the host is located */
 413   as_comp = ((network_element_info_t)
 414              xbt_lib_get_or_null(host_lib, name,
 415                                  ROUTING_HOST_LEVEL))->rc_component;
 416   return as_comp->name;
 417 }
 418
 419
 420 /**
 421  * \brief Get the AS father and the first elements of the chain
 422  *
 423  * \param src the source host name
 424  * \param dst the destination host name
 425  *
 426  * Get the common father of the to processing units, and the first different
 427  * father in the chain
 428  */
 429 static void elements_father(const char *src, const char *dst,
 430                             routing_component_t * res_father,
 431                             routing_component_t * res_src,
 432                             routing_component_t * res_dst)
 433 {
 434   xbt_assert(src && dst, "bad parameters for \"elements_father\" method");
 435 #define ELEMENTS_FATHER_MAXDEPTH 16     /* increase if it is not enough */
 436   routing_component_t src_as, dst_as;
 437   routing_component_t path_src[ELEMENTS_FATHER_MAXDEPTH];
 438   routing_component_t path_dst[ELEMENTS_FATHER_MAXDEPTH];
 439   int index_src = 0;
 440   int index_dst = 0;
 441   routing_component_t current;
 442   routing_component_t current_src;
 443   routing_component_t current_dst;
 444   routing_component_t father;
 445
 446   /* (1) find the as where the src and dst are located */
 447   network_element_info_t src_data = xbt_lib_get_or_null(host_lib, src,
 448                                                         ROUTING_HOST_LEVEL);
 449   network_element_info_t dst_data = xbt_lib_get_or_null(host_lib, dst,
 450                                                         ROUTING_HOST_LEVEL);
 451   if (!src_data)
 452     src_data = xbt_lib_get_or_null(as_router_lib, src, ROUTING_ASR_LEVEL);
 453   if (!dst_data)
 454     dst_data = xbt_lib_get_or_null(as_router_lib, dst, ROUTING_ASR_LEVEL);
 455   src_as = src_data->rc_component;
 456   dst_as = dst_data->rc_component;
 457
 458   xbt_assert(src_as && dst_as,
 459              "Ask for route \"from\"(%s) or \"to\"(%s) no found", src, dst);
 460
 461   /* (2) find the path to the root routing component */
 462   for (current = src_as; current != NULL; current = current->routing_father) {
 463     if (index_src >= ELEMENTS_FATHER_MAXDEPTH)
 464       xbt_die("ELEMENTS_FATHER_MAXDEPTH should be increased for path_src");
 465     path_src[index_src++] = current;
 466   }
 467   for (current = dst_as; current != NULL; current = current->routing_father) {
 468     if (index_dst >= ELEMENTS_FATHER_MAXDEPTH)
 469       xbt_die("ELEMENTS_FATHER_MAXDEPTH should be increased for path_dst");
 470     path_dst[index_dst++] = current;
 471   }
 472
 473   /* (3) find the common father */
 474   do {
 475     current_src = path_src[--index_src];
 476     current_dst = path_dst[--index_dst];
 477   } while (index_src > 0 && index_dst > 0 && current_src == current_dst);
 478
 479   /* (4) they are not in the same routing component, make the path */
 480   if (current_src == current_dst)
 481     father = current_src;
 482   else
 483     father = path_src[index_src + 1];
 484
 485   /* (5) result generation */
 486   *res_father = father;         /* first the common father of src and dst */
 487   *res_src = current_src;       /* second the first different father of src */
 488   *res_dst = current_dst;       /* three  the first different father of dst */
 489
 490 #undef ELEMENTS_FATHER_MAXDEPTH
 491 }
 492
 493 /* Global Business methods */
 494
 495 /**
 496  * \brief Recursive function for get_route_latency
 497  *
 498  * \param src the source host name
 499  * \param dst the destination host name
 500  * \param *e_route the route where the links are stored
 501  * \param *latency the latency, if needed
 502  *
 503  * This function is called by "get_route" and "get_latency". It allows to walk
 504  * recursively through the routing components tree.
 505  */
 506 static void _get_route_latency(const char *src, const char *dst,
 507                                xbt_dynar_t * route, double *latency)
 508 {
 509   XBT_DEBUG("Solve route/latency  \"%s\" to \"%s\"", src, dst);
 510   xbt_assert(src && dst, "bad parameters for \"_get_route_latency\" method");
 511
 512   routing_component_t common_father;
 513   routing_component_t src_father;
 514   routing_component_t dst_father;
 515   elements_father(src, dst, &common_father, &src_father, &dst_father);
 516
 517   if (src_father == dst_father) {       /* SURF_ROUTING_BASE */
 518
 519     route_extended_t e_route = NULL;
 520     if (route) {
 521       e_route = common_father->get_route(common_father, src, dst);
 522       xbt_assert(e_route, "no route between \"%s\" and \"%s\"", src, dst);
 523       *route = e_route->generic_route.link_list;
 524     }
 525     if (latency) {
 526       *latency = common_father->get_latency(common_father, src, dst, e_route);
 527       xbt_assert(*latency >= 0.0,
 528                  "latency error on route between \"%s\" and \"%s\"", src, dst);
 529     }
 530     if (e_route) {
 531       xbt_free(e_route->src_gateway);
 532       xbt_free(e_route->dst_gateway);
 533       xbt_free(e_route);
 534     }
 535
 536   } else {                      /* SURF_ROUTING_RECURSIVE */
 537
 538     route_extended_t e_route_bypass = NULL;
 539     if (common_father->get_bypass_route)
 540       e_route_bypass = common_father->get_bypass_route(common_father, src, dst);
 541
 542     xbt_assert(!latency || !e_route_bypass,
 543                "Bypass cannot work yet with get_latency");
 544
 545     route_extended_t e_route_cnt = e_route_bypass
 546         ? e_route_bypass : common_father->get_route(common_father,
 547                                                     src_father->name,
 548                                                     dst_father->name);
 549
 550     xbt_assert(e_route_cnt, "no route between \"%s\" and \"%s\"",
 551                src_father->name, dst_father->name);
 552
 553     xbt_assert((e_route_cnt->src_gateway == NULL) ==
 554                (e_route_cnt->dst_gateway == NULL),
 555                "bad gateway for route between \"%s\" and \"%s\"", src, dst);
 556
 557     if (route) {
 558       *route = xbt_dynar_new(global_routing->size_of_link, NULL);
 559     }
 560     if (latency) {
 561       *latency = common_father->get_latency(common_father,
 562                                             src_father->name, dst_father->name,
 563                                             e_route_cnt);
 564       xbt_assert(*latency >= 0.0,
 565                  "latency error on route between \"%s\" and \"%s\"",
 566                  src_father->name, dst_father->name);
 567     }
 568
 569     void *link;
 570     unsigned int cpt;
 571
 572     if (strcmp(src, e_route_cnt->src_gateway)) {
 573       double latency_src;
 574       xbt_dynar_t route_src;
 575
 576       _get_route_latency(src, e_route_cnt->src_gateway,
 577                          (route ? &route_src : NULL),
 578                          (latency ? &latency_src : NULL));
 579       if (route) {
 580         xbt_assert(route_src, "no route between \"%s\" and \"%s\"",
 581                    src, e_route_cnt->src_gateway);
 582         xbt_dynar_foreach(route_src, cpt, link) {
 583           xbt_dynar_push(*route, &link);
 584         }
 585         xbt_dynar_free(&route_src);
 586       }
 587       if (latency) {
 588         xbt_assert(latency_src >= 0.0,
 589                    "latency error on route between \"%s\" and \"%s\"",
 590                    src, e_route_cnt->src_gateway);
 591         *latency += latency_src;
 592       }
 593     }
 594
 595     if (route) {
 596       xbt_dynar_foreach(e_route_cnt->generic_route.link_list, cpt, link) {
 597         xbt_dynar_push(*route, &link);
 598       }
 599     }
 600
 601     if (strcmp(e_route_cnt->dst_gateway, dst)) {
 602       double latency_dst;
 603       xbt_dynar_t route_dst;
 604
 605       _get_route_latency(e_route_cnt->dst_gateway, dst,
 606                          (route ? &route_dst : NULL),
 607                          (latency ? &latency_dst : NULL));
 608       if (route) {
 609         xbt_assert(route_dst, "no route between \"%s\" and \"%s\"",
 610                    e_route_cnt->dst_gateway, dst);
 611         xbt_dynar_foreach(route_dst, cpt, link) {
 612           xbt_dynar_push(*route, &link);
 613         }
 614         xbt_dynar_free(&route_dst);
 615       }
 616       if (latency) {
 617         xbt_assert(latency_dst >= 0.0,
 618                    "latency error on route between \"%s\" and \"%s\"",
 619                    e_route_cnt->dst_gateway, dst);
 620         *latency += latency_dst;
 621       }
 622     }
 623
 624     generic_free_extended_route(e_route_cnt);
 625   }
 626 }
 627
 628 /**
 629  * \brief Generic function for get_route, get_route_no_cleanup, and get_latency
 630  */
 631 static void get_route_latency(const char *src, const char *dst,
 632                               xbt_dynar_t * route, double *latency, int cleanup)
 633 {
 634   _get_route_latency(src, dst, route, latency);
 635   xbt_assert(!route || *route, "no route between \"%s\" and \"%s\"", src, dst);
 636   xbt_assert(!latency || *latency >= 0.0,
 637              "latency error on route between \"%s\" and \"%s\"", src, dst);
 638   if (route) {
 639     xbt_dynar_free(&global_routing->last_route);
 640     global_routing->last_route = cleanup ? *route : NULL;
 641   }
 642 }
 643
 644 /**
 645  * \brief Generic method: find a route between hosts
 646  *
 647  * \param src the source host name
 648  * \param dst the destination host name
 649  *
 650  * walk through the routing components tree and find a route between hosts
 651  * by calling the differents "get_route" functions in each routing component.
 652  * No need to free the returned dynar. It will be freed at the next call.
 653  */
 654 static xbt_dynar_t get_route(const char *src, const char *dst)
 655 {
 656   xbt_dynar_t route = NULL;
 657   get_route_latency(src, dst, &route, NULL, 1);
 658   return route;
 659 }
 660
 661 /**
 662  * \brief Generic method: find a route between hosts
 663  *
 664  * \param src the source host name
 665  * \param dst the destination host name
 666  *
 667  * same as get_route, but return NULL if any exception is raised.
 668  */
 669 static xbt_dynar_t get_route_or_null(const char *src, const char *dst)
 670 {
 671   xbt_dynar_t route = NULL;
 672   xbt_ex_t exception;
 673   TRY {
 674     get_route_latency(src, dst, &route, NULL, 1);
 675   } CATCH(exception) {
 676     xbt_ex_free(exception);
 677     return NULL;
 678   }
 679   return route;
 680 }
 681
 682 /**
 683  * \brief Generic method: find a route between hosts
 684  *
 685  * \param src the source host name
 686  * \param dst the destination host name
 687  *
 688  * walk through the routing components tree and find a route between hosts
 689  * by calling the differents "get_route" functions in each routing component.
 690  * Leaves the caller the responsability to clean the returned dynar.
 691  */
 692 static xbt_dynar_t get_route_no_cleanup(const char *src, const char *dst)
 693 {
 694   xbt_dynar_t route = NULL;
 695   get_route_latency(src, dst, &route, NULL, 0);
 696   return route;
 697 }
 698
 699 /*Get Latency*/
 700 static double get_latency(const char *src, const char *dst)
 701 {
 702   double latency = -1.0;
 703   get_route_latency(src, dst, NULL, &latency, 0);
 704   return latency;
 705 }
 706
 707 static int surf_parse_models_setup_already_called = 0;
 708 /* Call the last initialization functions, that must be called after the
 709  * <config> tag, if any, and before the first of cluster|peer|AS|trace|trace_connect
 710  */
 711 void surf_parse_models_setup()
 712 {
 713   if (surf_parse_models_setup_already_called)
 714     return;
 715   surf_parse_models_setup_already_called = 1;
 716   surf_config_models_setup();
 717 }
 718
 719
 720 /**
 721  * \brief Recursive function for finalize
 722  *
 723  * \param rc the source host name
 724  *
 725  * This fuction is call by "finalize". It allow to finalize the
 726  * AS or routing components. It delete all the structures.
 727  */
 728 static void _finalize(routing_component_t rc)
 729 {
 730   if (rc) {
 731     xbt_dict_cursor_t cursor = NULL;
 732     char *key;
 733     routing_component_t elem;
 734     xbt_dict_foreach(rc->routing_sons, cursor, key, elem) {
 735       _finalize(elem);
 736     }
 737     xbt_dict_t tmp_sons = rc->routing_sons;
 738     char *tmp_name = rc->name;
 739     xbt_dict_free(&tmp_sons);
 740     xbt_free(tmp_name);
 741     xbt_assert(rc->finalize, "no defined method \"finalize\" in \"%s\"",
 742                current_routing->name);
 743     (*(rc->finalize)) (rc);
 744   }
 745 }
 746
 747 /**
 748  * \brief Generic method: delete all the routing structures
 749  *
 750  * walk through the routing components tree and delete the structures
 751  * by calling the differents "finalize" functions in each routing component
 752  */
 753 static void finalize(void)
 754 {
 755   /* delete recursively all the tree */
 756   _finalize(global_routing->root);
 757   /* delete last_route */
 758   xbt_dynar_free(&(global_routing->last_route));
 759   /* delete global routing structure */
 760   xbt_free(global_routing);
 761   /* make sure that we will reinit the models while loading the platf once reinited -- HACK but there is no proper surf_routing_init() */
 762   surf_parse_models_setup_already_called = 0;
 763 }
 764
 765 static xbt_dynar_t recursive_get_onelink_routes(routing_component_t rc)
 766 {
 767   xbt_dynar_t ret = xbt_dynar_new(sizeof(onelink_t), xbt_free);
 768
 769   //adding my one link routes
 770   unsigned int cpt;
 771   void *link;
 772   xbt_dynar_t onelink_mine = rc->get_onelink_routes(rc);
 773   if (onelink_mine) {
 774     xbt_dynar_foreach(onelink_mine, cpt, link) {
 775       xbt_dynar_push(ret, &link);
 776     }
 777   }
 778   //recursing
 779   char *key;
 780   xbt_dict_cursor_t cursor = NULL;
 781   routing_component_t rc_child;
 782   xbt_dict_foreach(rc->routing_sons, cursor, key, rc_child) {
 783     xbt_dynar_t onelink_child = recursive_get_onelink_routes(rc_child);
 784     if (onelink_child) {
 785       xbt_dynar_foreach(onelink_child, cpt, link) {
 786         xbt_dynar_push(ret, &link);
 787       }
 788     }
 789   }
 790   return ret;
 791 }
 792
 793 static xbt_dynar_t get_onelink_routes(void)
 794 {
 795   return recursive_get_onelink_routes(global_routing->root);
 796 }
 797
 798 e_surf_network_element_type_t get_network_element_type(const char *name)
 799 {
 800   network_element_info_t rc = NULL;
 801
 802   rc = xbt_lib_get_or_null(host_lib, name, ROUTING_HOST_LEVEL);
 803   if (rc)
 804     return rc->rc_type;
 805
 806   rc = xbt_lib_get_or_null(as_router_lib, name, ROUTING_ASR_LEVEL);
 807   if (rc)
 808     return rc->rc_type;
 809
 810   return SURF_NETWORK_ELEMENT_NULL;
 811 }
 812
 813 /**
 814  * \brief Generic method: create the global routing schema
 815  *
 816  * Make a global routing structure and set all the parsing functions.
 817  */
 818 void routing_model_create(size_t size_of_links, void *loopback)
 819 {
 820   /* config the uniq global routing */
 821   global_routing = xbt_new0(s_routing_global_t, 1);
 822   global_routing->root = NULL;
 823   global_routing->get_route = get_route;
 824   global_routing->get_route_or_null = get_route_or_null;
 825   global_routing->get_latency = get_latency;
 826   global_routing->get_route_no_cleanup = get_route_no_cleanup;
 827   global_routing->get_onelink_routes = get_onelink_routes;
 828   global_routing->get_route_latency = get_route_latency;
 829   global_routing->get_network_element_type = get_network_element_type;
 830   global_routing->finalize = finalize;
 831   global_routing->loopback = loopback;
 832   global_routing->size_of_link = size_of_links;
 833   global_routing->last_route = NULL;
 834   /* no current routing at moment */
 835   current_routing = NULL;
 836 }
 837
 838
 839 /* ************************************************** */
 840 /* ********** PATERN FOR NEW ROUTING **************** */
 841
 842 /* The minimal configuration of a new routing model need the next functions,
 843  * also you need to set at the start of the file, the new model in the model
 844  * list. Remember keep the null ending of the list.
 845  */
 846 /*** Routing model structure ***/
 847 // typedef struct {
 848 //   s_routing_component_t generic_routing;
 849 //   /* things that your routing model need */
 850 // } s_routing_component_NEW_t,*routing_component_NEW_t;
 851
 852 /*** Parse routing model functions ***/
 853 // static void model_NEW_set_processing_unit(routing_component_t rc, const char* name) {}
 854 // static void model_NEW_set_autonomous_system(routing_component_t rc, const char* name) {}
 855 // static void model_NEW_set_route(routing_component_t rc, const char* src, const char* dst, route_t route) {}
 856 // static void model_NEW_set_ASroute(routing_component_t rc, const char* src, const char* dst, route_extended_t route) {}
 857 // static void model_NEW_set_bypassroute(routing_component_t rc, const char* src, const char* dst, route_extended_t e_route) {}
 858
 859 /*** Business methods ***/
 860 // static route_extended_t NEW_get_route(routing_component_t rc, const char* src,const char* dst) {return NULL;}
 861 // static route_extended_t NEW_get_bypass_route(routing_component_t rc, const char* src,const char* dst) {return NULL;}
 862 // static void NEW_finalize(routing_component_t rc) { xbt_free(rc);}
 863
 864 /*** Creation routing model functions ***/
 865 // static void* model_NEW_create(void) {
 866 //   routing_component_NEW_t new_component =  xbt_new0(s_routing_component_NEW_t,1);
 867 //   new_component->generic_routing.set_processing_unit = model_NEW_set_processing_unit;
 868 //   new_component->generic_routing.set_autonomous_system = model_NEW_set_autonomous_system;
 869 //   new_component->generic_routing.set_route = model_NEW_set_route;
 870 //   new_component->generic_routing.set_ASroute = model_NEW_set_ASroute;
 871 //   new_component->generic_routing.set_bypassroute = model_NEW_set_bypassroute;
 872 //   new_component->generic_routing.get_route = NEW_get_route;
 873 //   new_component->generic_routing.get_bypass_route = NEW_get_bypass_route;
 874 //   new_component->generic_routing.finalize = NEW_finalize;
 875 //   /* initialization of internal structures */
 876 //   return new_component;
 877 // } /* mandatory */
 878 // static void  model_NEW_load(void) {}   /* mandatory */
 879 // static void  model_NEW_unload(void) {} /* mandatory */
 880 // static void  model_NEW_end(void) {}    /* mandatory */
 881
 882 /* ************************************************************************** */
 883 /* ************************* GENERIC PARSE FUNCTIONS ************************ */
 884
 885
 886 static void routing_parse_cluster(void)
 887 {
 888   char *host_id, *groups, *link_id = NULL;
 889
 890   s_sg_platf_host_cbarg_t host;
 891   s_sg_platf_link_cbarg_t link;
 892
 893   if (strcmp(struct_cluster->availability_trace, "")
 894       || strcmp(struct_cluster->state_trace, "")) {
 895     if (xbt_dict_size(patterns) == 0)
 896       patterns = xbt_dict_new();
 897     xbt_dict_set(patterns, "id", xbt_strdup(struct_cluster->id), free);
 898     xbt_dict_set(patterns, "prefix", xbt_strdup(struct_cluster->prefix), free);
 899     xbt_dict_set(patterns, "suffix", xbt_strdup(struct_cluster->suffix), free);
 900   }
 901
 902   unsigned int iter;
 903   int start, end, i;
 904   xbt_dynar_t radical_elements;
 905   xbt_dynar_t radical_ends;
 906
 907   XBT_DEBUG("<AS id=\"%s\"\trouting=\"Cluster\">", struct_cluster->id);
 908   sg_platf_new_AS_open(struct_cluster->id, "Cluster");
 909
 910   //Make all hosts
 911   radical_elements = xbt_str_split(struct_cluster->radical, ",");
 912   xbt_dynar_foreach(radical_elements, iter, groups) {
 913     memset(&host, 0, sizeof(host));
 914
 915     radical_ends = xbt_str_split(groups, "-");
 916     start = surf_parse_get_int(xbt_dynar_get_as(radical_ends, 0, char *));
 917
 918     switch (xbt_dynar_length(radical_ends)) {
 919     case 1:
 920       end = start;
 921       break;
 922     case 2:
 923       end = surf_parse_get_int(xbt_dynar_get_as(radical_ends, 1, char *));
 924       break;
 925     default:
 926       surf_parse_error("Malformed radical");
 927       break;
 928     }
 929     for (i = start; i <= end; i++) {
 930       host_id =
 931           bprintf("%s%d%s", struct_cluster->prefix, i, struct_cluster->suffix);
 932       link_id = bprintf("%s_link_%d", struct_cluster->id, i);
 933
 934       XBT_DEBUG("<host\tid=\"%s\"\tpower=\"%f\">", host_id,
 935                 struct_cluster->power);
 936       host.id = host_id;
 937       if (strcmp(struct_cluster->availability_trace, "")) {
 938         xbt_dict_set(patterns, "radical", bprintf("%d", i), xbt_free);
 939         char *tmp_availability_file =
 940             xbt_strdup(struct_cluster->availability_trace);
 941         xbt_str_varsubst(tmp_availability_file, patterns);
 942         XBT_DEBUG("\tavailability_file=\"%s\"", tmp_availability_file);
 943         host.power_trace = tmgr_trace_new(tmp_availability_file);
 944         xbt_free(tmp_availability_file);
 945       } else {
 946         XBT_DEBUG("\tavailability_file=\"\"");
 947       }
 948       if (strcmp(struct_cluster->state_trace, "")) {
 949         char *tmp_state_file = xbt_strdup(struct_cluster->state_trace);
 950         xbt_str_varsubst(tmp_state_file, patterns);
 951         XBT_DEBUG("\tstate_file=\"%s\"", tmp_state_file);
 952         host.state_trace = tmgr_trace_new(tmp_state_file);
 953         xbt_free(tmp_state_file);
 954       } else {
 955         XBT_DEBUG("\tstate_file=\"\"");
 956       }
 957
 958       host.power_peak = struct_cluster->power;
 959       host.power_scale = 1.0;
 960       host.core_amount = struct_cluster->core_amount;
 961       host.initial_state = SURF_RESOURCE_ON;
 962       host.coord = "";
 963       sg_platf_new_host(&host);
 964       XBT_DEBUG("</host>");
 965
 966       XBT_DEBUG("<link\tid=\"%s\"\tbw=\"%f\"\tlat=\"%f\"/>", link_id,
 967                 struct_cluster->bw, struct_cluster->lat);
 968
 969       memset(&link, 0, sizeof(link));
 970       link.id = link_id;
 971       link.bandwidth = struct_cluster->bw;
 972       link.latency = struct_cluster->lat;
 973       link.state = SURF_RESOURCE_ON;
 974
 975       switch (struct_cluster->sharing_policy) {
 976       case A_surfxml_cluster_sharing_policy_SHARED:
 977         link.policy = SURF_LINK_SHARED;
 978         break;
 979       case A_surfxml_cluster_sharing_policy_FULLDUPLEX:
 980         link.policy = SURF_LINK_FULLDUPLEX;
 981         break;
 982       case A_surfxml_cluster_sharing_policy_FATPIPE:
 983         link.policy = SURF_LINK_FATPIPE;
 984         break;
 985       default:
 986         surf_parse_error(bprintf
 987                          ("Invalid cluster sharing policy for cluster %s",
 988                           struct_cluster->id));
 989         break;
 990       }
 991       sg_platf_new_link(&link);
 992
 993       surf_parsing_link_up_down_t info =
 994           xbt_new0(s_surf_parsing_link_up_down_t, 1);
 995       if (link.policy == SURF_LINK_FULLDUPLEX) {
 996         char *tmp_link = bprintf("%s_UP", link_id);
 997         info->link_up =
 998             xbt_lib_get_or_null(link_lib, tmp_link, SURF_LINK_LEVEL);
 999         free(tmp_link);
1000         tmp_link = bprintf("%s_DOWN", link_id);
1001         info->link_down =
1002             xbt_lib_get_or_null(link_lib, tmp_link, SURF_LINK_LEVEL);
1003         free(tmp_link);
1004       } else {
1005         info->link_up = xbt_lib_get_or_null(link_lib, link_id, SURF_LINK_LEVEL);
1006         info->link_down = info->link_up;
1007       }
1008       surf_routing_cluster_add_link(host_id, info);
1009
1010       xbt_free(link_id);
1011       xbt_free(host_id);
1012     }
1013
1014     xbt_dynar_free(&radical_ends);
1015   }
1016   xbt_dynar_free(&radical_elements);
1017
1018   // Add a router. It is magically used thanks to the way in which surf_routing_cluster is written, and it's very useful to connect clusters together
1019   XBT_DEBUG(" ");
1020   XBT_DEBUG("<router id=\"%s\"/>", struct_cluster->router_id);
1021   s_sg_platf_router_cbarg_t router;
1022   char *newid = NULL;
1023   memset(&router, 0, sizeof(router));
1024   router.id = struct_cluster->router_id;
1025   router.coord = "";
1026   if (!router.id || !strcmp(router.id, ""))
1027     router.id = newid =
1028         bprintf("%s%s_router%s", struct_cluster->prefix, struct_cluster->id,
1029                 struct_cluster->suffix);
1030   sg_platf_new_router(&router);
1031   free(newid);
1032
1033   //Make the backbone
1034   if ((struct_cluster->bb_bw != 0) && (struct_cluster->bb_lat != 0)) {
1035     char *link_backbone = bprintf("%s_backbone", struct_cluster->id);
1036     XBT_DEBUG("<link\tid=\"%s\" bw=\"%f\" lat=\"%f\"/>", link_backbone,
1037               struct_cluster->bb_bw, struct_cluster->bb_lat);
1038
1039     memset(&link, 0, sizeof(link));
1040     link.id = link_backbone;
1041     link.bandwidth = struct_cluster->bb_bw;
1042     link.latency = struct_cluster->bb_lat;
1043     link.state = SURF_RESOURCE_ON;
1044
1045     switch (struct_cluster->bb_sharing_policy) {
1046     case A_surfxml_cluster_bb_sharing_policy_FATPIPE:
1047       link.policy = SURF_LINK_FATPIPE;
1048       break;
1049     case A_surfxml_cluster_bb_sharing_policy_SHARED:
1050       link.policy = SURF_LINK_SHARED;
1051       break;
1052     default:
1053       surf_parse_error(bprintf
1054                        ("Invalid bb sharing policy in cluster %s",
1055                         struct_cluster->id));
1056       break;
1057     }
1058
1059     sg_platf_new_link(&link);
1060
1061     surf_parsing_link_up_down_t info =
1062         xbt_new0(s_surf_parsing_link_up_down_t, 1);
1063     info->link_up =
1064         xbt_lib_get_or_null(link_lib, link_backbone, SURF_LINK_LEVEL);
1065     info->link_down = info->link_up;
1066     surf_routing_cluster_add_link(struct_cluster->id, info);
1067
1068     free(link_backbone);
1069   }
1070
1071   XBT_DEBUG(" ");
1072
1073   char *new_suffix = xbt_strdup("");
1074
1075   radical_elements = xbt_str_split(struct_cluster->suffix, ".");
1076   xbt_dynar_foreach(radical_elements, iter, groups) {
1077     if (strcmp(groups, "")) {
1078       char *old_suffix = new_suffix;
1079       new_suffix = bprintf("%s\\.%s", old_suffix, groups);
1080       free(old_suffix);
1081     }
1082   }
1083
1084   xbt_dynar_free(&radical_elements);
1085   xbt_free(new_suffix);
1086
1087   if (strcmp(struct_cluster->availability_trace, "")
1088       || strcmp(struct_cluster->state_trace, ""))
1089     xbt_dict_free(&patterns);
1090
1091   XBT_DEBUG("</AS>");
1092   sg_platf_new_AS_close();
1093   XBT_DEBUG(" ");
1094 }
1095
1096 /*
1097  * This function take a string and replace parameters from patterns dict.
1098  * It returns the new value.
1099  */
1100 static char *replace_random_parameter(char *string)
1101 {
1102   char *test_string = NULL;
1103
1104   if (xbt_dict_size(random_value) == 0)
1105     return string;
1106
1107   string = xbt_str_varsubst(string, patterns);  // for patterns of cluster
1108   test_string = bprintf("${%s}", string);
1109   test_string = xbt_str_varsubst(test_string, random_value);    //Add ${xxxxx} for random Generator
1110
1111   if (strcmp(test_string, "")) {        //if not empty, keep this value.
1112     xbt_free(string);
1113     string = test_string;
1114   }                             //In other case take old value (without ${})
1115   else
1116     free(test_string);
1117   return string;
1118 }
1119
1120 static void routing_parse_postparse(void)
1121 {
1122   xbt_dict_free(&random_value);
1123   xbt_dict_free(&patterns);
1124 }
1125
1126 static void routing_parse_peer(sg_platf_peer_cbarg_t peer)
1127 {
1128   static int AX_ptr = 0;
1129   char *host_id = NULL;
1130   char *router_id, *link_router, *link_backbone, *link_id_up, *link_id_down;
1131
1132   static unsigned int surfxml_buffer_stack_stack_ptr = 1;
1133   static unsigned int surfxml_buffer_stack_stack[1024];
1134
1135   surfxml_buffer_stack_stack[0] = 0;
1136
1137   surfxml_bufferstack_push(1);
1138
1139   XBT_DEBUG("<AS id=\"%s\"\trouting=\"Full\">", peer->id);
1140   sg_platf_new_AS_open(peer->id, "Full");
1141
1142   XBT_DEBUG(" ");
1143   host_id = HOST_PEER(peer->id);
1144   router_id = ROUTER_PEER(peer->id);
1145   link_id_up = LINK_UP_PEER(peer->id);
1146   link_id_down = LINK_DOWN_PEER(peer->id);
1147
1148   link_router = bprintf("%s_link_router", peer->id);
1149   link_backbone = bprintf("%s_backbone", peer->id);
1150
1151   XBT_DEBUG("<host\tid=\"%s\"\tpower=\"%f\"/>", host_id, peer->power);
1152   s_sg_platf_host_cbarg_t host;
1153   memset(&host, 0, sizeof(host));
1154   host.initial_state = SURF_RESOURCE_ON;
1155   host.id = host_id;
1156   host.power_peak = peer->power;
1157   host.power_scale = 1.0;
1158   host.power_trace = peer->availability_trace;
1159   host.state_trace = peer->state_trace;
1160   host.core_amount = 1;
1161   sg_platf_new_host(&host);
1162
1163
1164   XBT_DEBUG("<router id=\"%s\"\tcoordinates=\"%s\"/>", router_id, peer->coord);
1165   s_sg_platf_router_cbarg_t router;
1166   memset(&router, 0, sizeof(router));
1167   router.id = router_id;
1168   router.coord = peer->coord;
1169   sg_platf_new_router(&router);
1170
1171   XBT_DEBUG("<link\tid=\"%s\"\tbw=\"%f\"\tlat=\"%f\"/>", link_id_up,
1172             peer->bw_in, peer->lat);
1173   s_sg_platf_link_cbarg_t link;
1174   memset(&link, 0, sizeof(link));
1175   link.state = SURF_RESOURCE_ON;
1176   link.policy = SURF_LINK_SHARED;
1177   link.id = link_id_up;
1178   link.bandwidth = peer->bw_in;
1179   link.latency = peer->lat;
1180   sg_platf_new_link(&link);
1181
1182   // FIXME: dealing with full duplex is not the role of this piece of code, I'd say [Mt]
1183   // Instead, it should be created fullduplex, and the models will do what's needed in this case
1184   XBT_DEBUG("<link\tid=\"%s\"\tbw=\"%f\"\tlat=\"%f\"/>", link_id_down,
1185             peer->bw_out, peer->lat);
1186   link.id = link_id_down;
1187   sg_platf_new_link(&link);
1188
1189   XBT_DEBUG(" ");
1190
1191   // begin here
1192   XBT_DEBUG("<route\tsrc=\"%s\"\tdst=\"%s\"", host_id, router_id);
1193   XBT_DEBUG("symmetrical=\"NO\">");
1194   SURFXML_BUFFER_SET(route_src, host_id);
1195   SURFXML_BUFFER_SET(route_dst, router_id);
1196   A_surfxml_route_symmetrical = A_surfxml_route_symmetrical_NO;
1197   SURFXML_START_TAG(route);
1198
1199   XBT_DEBUG("<link_ctn\tid=\"%s\"/>", link_id_up);
1200   SURFXML_BUFFER_SET(link_ctn_id, link_id_up);
1201   A_surfxml_link_ctn_direction = A_surfxml_link_ctn_direction_NONE;
1202   SURFXML_START_TAG(link_ctn);
1203   SURFXML_END_TAG(link_ctn);
1204
1205   XBT_DEBUG("</route>");
1206   SURFXML_END_TAG(route);
1207
1208   //Opposite Route
1209   XBT_DEBUG("<route\tsrc=\"%s\"\tdst=\"%s\"", router_id, host_id);
1210   XBT_DEBUG("symmetrical=\"NO\">");
1211   SURFXML_BUFFER_SET(route_src, router_id);
1212   SURFXML_BUFFER_SET(route_dst, host_id);
1213   A_surfxml_route_symmetrical = A_surfxml_route_symmetrical_NO;
1214   SURFXML_START_TAG(route);
1215
1216   XBT_DEBUG("<link_ctn\tid=\"%s\"/>", link_id_down);
1217   SURFXML_BUFFER_SET(link_ctn_id, link_id_down);
1218   A_surfxml_link_ctn_direction = A_surfxml_link_ctn_direction_NONE;
1219   SURFXML_START_TAG(link_ctn);
1220   SURFXML_END_TAG(link_ctn);
1221
1222   XBT_DEBUG("</route>");
1223   SURFXML_END_TAG(route);
1224
1225   XBT_DEBUG("</AS>");
1226   sg_platf_new_AS_close();
1227   XBT_DEBUG(" ");
1228
1229   //xbt_dynar_free(&tab_elements_num);
1230   free(host_id);
1231   free(router_id);
1232   free(link_router);
1233   free(link_backbone);
1234   free(link_id_up);
1235   free(link_id_down);
1236   surfxml_bufferstack_pop(1);
1237 }
1238
1239 static void routing_parse_Srandom(void)
1240 {
1241   double mean, std, min, max, seed;
1242   char *random_id = A_surfxml_random_id;
1243   char *random_radical = A_surfxml_random_radical;
1244   char *rd_name = NULL;
1245   char *rd_value;
1246   mean = surf_parse_get_double(A_surfxml_random_mean);
1247   std = surf_parse_get_double(A_surfxml_random_std_deviation);
1248   min = surf_parse_get_double(A_surfxml_random_min);
1249   max = surf_parse_get_double(A_surfxml_random_max);
1250   seed = surf_parse_get_double(A_surfxml_random_seed);
1251
1252   double res = 0;
1253   int i = 0;
1254   random_data_t random = xbt_new0(s_random_data_t, 1);
1255   char *tmpbuf;
1256
1257   xbt_dynar_t radical_elements;
1258   unsigned int iter;
1259   char *groups;
1260   int start, end;
1261   xbt_dynar_t radical_ends;
1262
1263   random->generator = A_surfxml_random_generator;
1264   random->seed = seed;
1265   random->min = min;
1266   random->max = max;
1267
1268   /* Check user stupidities */
1269   if (max < min)
1270     THROWF(arg_error, 0, "random->max < random->min (%f < %f)", max, min);
1271   if (mean < min)
1272     THROWF(arg_error, 0, "random->mean < random->min (%f < %f)", mean, min);
1273   if (mean > max)
1274     THROWF(arg_error, 0, "random->mean > random->max (%f > %f)", mean, max);
1275
1276   /* normalize the mean and standard deviation before storing */
1277   random->mean = (mean - min) / (max - min);
1278   random->std = std / (max - min);
1279
1280   if (random->mean * (1 - random->mean) < random->std * random->std)
1281     THROWF(arg_error, 0, "Invalid mean and standard deviation (%f and %f)",
1282            random->mean, random->std);
1283
1284   XBT_DEBUG
1285       ("id = '%s' min = '%f' max = '%f' mean = '%f' std_deviatinon = '%f' generator = '%d' seed = '%ld' radical = '%s'",
1286        random_id, random->min, random->max, random->mean, random->std,
1287        random->generator, random->seed, random_radical);
1288
1289   if (xbt_dict_size(random_value) == 0)
1290     random_value = xbt_dict_new();
1291
1292   if (!strcmp(random_radical, "")) {
1293     res = random_generate(random);
1294     rd_value = bprintf("%f", res);
1295     xbt_dict_set(random_value, random_id, rd_value, free);
1296   } else {
1297     radical_elements = xbt_str_split(random_radical, ",");
1298     xbt_dynar_foreach(radical_elements, iter, groups) {
1299       radical_ends = xbt_str_split(groups, "-");
1300       switch (xbt_dynar_length(radical_ends)) {
1301       case 1:
1302         xbt_assert(!xbt_dict_get_or_null(random_value, random_id),
1303                    "Custom Random '%s' already exists !", random_id);
1304         res = random_generate(random);
1305         tmpbuf =
1306             bprintf("%s%d", random_id,
1307                     atoi(xbt_dynar_getfirst_as(radical_ends, char *)));
1308         xbt_dict_set(random_value, tmpbuf, bprintf("%f", res), free);
1309         xbt_free(tmpbuf);
1310         break;
1311
1312       case 2:
1313         start = surf_parse_get_int(xbt_dynar_get_as(radical_ends, 0, char *));
1314         end = surf_parse_get_int(xbt_dynar_get_as(radical_ends, 1, char *));
1315         for (i = start; i <= end; i++) {
1316           xbt_assert(!xbt_dict_get_or_null(random_value, random_id),
1317                      "Custom Random '%s' already exists !", bprintf("%s%d",
1318                                                                     random_id,
1319                                                                     i));
1320           res = random_generate(random);
1321           tmpbuf = bprintf("%s%d", random_id, i);
1322           xbt_dict_set(random_value, tmpbuf, bprintf("%f", res), free);
1323           xbt_free(tmpbuf);
1324         }
1325         break;
1326       default:
1327         XBT_INFO("Malformed radical");
1328         break;
1329       }
1330       res = random_generate(random);
1331       rd_name = bprintf("%s_router", random_id);
1332       rd_value = bprintf("%f", res);
1333       xbt_dict_set(random_value, rd_name, rd_value, free);
1334
1335       xbt_dynar_free(&radical_ends);
1336     }
1337     free(rd_name);
1338     xbt_dynar_free(&radical_elements);
1339   }
1340 }
1341
1342 void routing_register_callbacks()
1343 {
1344   sg_platf_host_add_cb(parse_S_host);
1345   sg_platf_router_add_cb(parse_S_router);
1346
1347   surfxml_add_callback(STag_surfxml_random_cb_list, &routing_parse_Srandom);
1348
1349   surfxml_add_callback(STag_surfxml_route_cb_list, &routing_parse_S_route);
1350   surfxml_add_callback(STag_surfxml_ASroute_cb_list, &routing_parse_S_ASroute);
1351   surfxml_add_callback(STag_surfxml_bypassRoute_cb_list,
1352                        &routing_parse_S_bypassRoute);
1353
1354   surfxml_add_callback(ETag_surfxml_link_ctn_cb_list, &routing_parse_link_ctn);
1355
1356   surfxml_add_callback(ETag_surfxml_route_cb_list, &routing_parse_E_route);
1357   surfxml_add_callback(ETag_surfxml_ASroute_cb_list, &routing_parse_E_ASroute);
1358   surfxml_add_callback(ETag_surfxml_bypassRoute_cb_list,
1359                        &routing_parse_E_bypassRoute);
1360
1361   surfxml_add_callback(STag_surfxml_cluster_cb_list, &routing_parse_cluster);
1362
1363   sg_platf_peer_add_cb(routing_parse_peer);
1364   sg_platf_postparse_add_cb(routing_parse_postparse);
1365
1366 #ifdef HAVE_TRACING
1367   instr_routing_define_callbacks();
1368 #endif
1369 }