Platform generation: generate routes

[simgrid.git] / src / surf / platf_generator.c

diff --git a/src/surf/platf_generator.c b/src/surf/platf_generator.c
index 0e50316..d21722f 100644 (file)
--- a/src/surf/platf_generator.c
+++ b/src/surf/platf_generator.c
@@ -8,6 +8,8 @@
 #include "surf_private.h"
 #include <math.h>
 
+XBT_LOG_NEW_DEFAULT_SUBCATEGORY(platf_generator, surf, "Platform Generator");
+
 static xbt_graph_t platform_graph = NULL;
 static xbt_dynar_t promoter_dynar = NULL;
 static xbt_dynar_t labeler_dynar = NULL;
@@ -466,6 +468,7 @@ void platf_graph_promote_to_cluster(context_node_t node, sg_platf_cluster_cbarg_
  */
 void platf_graph_link_label(context_edge_t edge, sg_platf_link_cbarg_t parameters) {
   memcpy(&(edge->link_parameters), parameters, sizeof(s_sg_platf_link_cbarg_t));
+  edge->labeled = TRUE;
 }
 
 /**
@@ -496,7 +499,8 @@ void platf_graph_promoter(platf_promoter_cb_t promoter_callback) {
  * it, and call platf_graph_link_label if needed.
  * You can register several callbacks: the first registered function will be
  * called first. If the link have not been labeled yet, the second function
- * will be called, and so on...
+ * will be called, and so on... All the links must have been labeled after
+ * all the calls.
  *
  * \param labeler_callback The callback function
  */
@@ -542,11 +546,15 @@ void platf_do_label(void) {
   dynar_edges = xbt_graph_get_edges(platform_graph);
   xbt_dynar_foreach(dynar_edges, i, graph_edge) {
     edge = (context_edge_t) xbt_graph_edge_get_data(graph_edge);
-    xbt_dynar_foreach(promoter_dynar, j, labeler_callback) {
-      if(edge->labeled == TRUE)
+    xbt_dynar_foreach(labeler_dynar, j, labeler_callback) {
+      if(edge->labeled)
         break;
       labeler_callback(edge);
     }
+    if(!edge->labeled) {
+      XBT_ERROR("All links of the generated platform are not labeled.");
+      xbt_die("Please check your generation parameters.");
+    }
   }
 }
 
@@ -564,6 +572,9 @@ void platf_generate(void) {
   xbt_dynar_t nodes = NULL;
   xbt_node_t graph_node = NULL;
   context_node_t node_data = NULL;
+  xbt_dynar_t edges = NULL;
+  xbt_edge_t graph_edge = NULL;
+  context_edge_t edge_data = NULL;
   unsigned int i;
 
   unsigned int last_host = 0;
@@ -571,12 +582,21 @@ void platf_generate(void) {
   unsigned int last_cluster = 0;
 
   sg_platf_host_cbarg_t host_parameters;
-  s_sg_platf_router_cbarg_t router_parameters; /* This one is not a pointer! */
   sg_platf_cluster_cbarg_t cluster_parameters;
+  sg_platf_link_cbarg_t link_parameters;
+  s_sg_platf_router_cbarg_t router_parameters; /* This one is not a pointer! */
+  s_sg_platf_route_cbarg_t route_parameters; /* neither this one! */
 
   router_parameters.coord = NULL;
+  route_parameters.symmetrical = FALSE;
+  route_parameters.src = NULL;
+  route_parameters.dst = NULL;
+  route_parameters.gw_dst = NULL;
+  route_parameters.gw_src = NULL;
+  route_parameters.link_list = NULL;
 
   nodes = xbt_graph_get_nodes(platform_graph);
+  edges = xbt_graph_get_edges(platform_graph);
 
   sg_platf_begin();
   surf_parse_init_callbacks();
@@ -585,6 +605,7 @@ void platf_generate(void) {
 
   sg_platf_new_AS_begin("random platform", A_surfxml_AS_routing_Floyd);
 
+  //Generate hosts, clusters and routers
   xbt_dynar_foreach(nodes, i, graph_node) {
     node_data = xbt_graph_node_get_data(graph_node);
     switch(node_data->kind) {
@@ -616,6 +637,55 @@ void platf_generate(void) {
     }
   }
 
+  //Generate links and routes
+  xbt_dynar_foreach(edges, i, graph_edge) {
+    xbt_node_t src = xbt_graph_edge_get_source(graph_edge);
+    xbt_node_t dst = xbt_graph_edge_get_target(graph_edge);
+    context_node_t src_data = xbt_graph_node_get_data(src);
+    context_node_t dst_data = xbt_graph_node_get_data(dst);
+    edge_data = xbt_graph_edge_get_data(graph_edge);
+    const char* temp = NULL;
+
+    //Add a link to the platform
+    link_parameters = &edge_data->link_parameters;
+    if(link_parameters->id == NULL) {
+      link_parameters->id = bprintf("link-%ld", edge_data->id);
+    }
+    sg_platf_new_link(link_parameters);
+
+    //Add a route matching this link
+    switch(src_data->kind) {
+      case ROUTER:
+        route_parameters.src = src_data->router_id;
+        break;
+      case CLUSTER:
+        route_parameters.src = src_data->cluster_parameters.id;
+        break;
+      case HOST:
+        route_parameters.src = src_data->host_parameters.id;
+    }
+    switch(dst_data->kind) {
+      case ROUTER:
+        route_parameters.dst = dst_data->router_id;
+        break;
+      case CLUSTER:
+        route_parameters.dst = dst_data->cluster_parameters.id;
+        break;
+      case HOST:
+        route_parameters.dst = dst_data->host_parameters.id;
+    }
+    sg_platf_route_begin(&route_parameters);
+    sg_platf_route_add_link(link_parameters->id, &route_parameters);
+    sg_platf_route_end(&route_parameters);
+
+    //Create the symmertical route
+    temp = route_parameters.dst;
+    route_parameters.dst = route_parameters.src;
+    route_parameters.src = temp;
+    sg_platf_route_begin(&route_parameters);
+    sg_platf_route_add_link(link_parameters->id, &route_parameters);
+    sg_platf_route_end(&route_parameters);
+  }
 
   sg_platf_new_AS_end();
   sg_platf_end();