X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/bee3400ba6e1daeca869db8753dc4d86bcda28ca..3736e0252d96679e19cfbe41f3c09833d3734386:/src/surf/sg_platf.c diff --git a/src/surf/sg_platf.c b/src/surf/sg_platf.c index 06e0c77007..1db868e816 100644 --- a/src/surf/sg_platf.c +++ b/src/surf/sg_platf.c @@ -15,6 +15,7 @@ xbt_dynar_t sg_platf_host_cb_list = NULL; // of sg_platf_host_cb_t xbt_dynar_t sg_platf_link_cb_list = NULL; // of sg_platf_link_cb_t xbt_dynar_t sg_platf_router_cb_list = NULL; // of sg_platf_router_cb_t xbt_dynar_t sg_platf_peer_cb_list = NULL; // of sg_platf_peer_cb_t +xbt_dynar_t sg_platf_cluster_cb_list = NULL; // of sg_platf_cluster_cb_t xbt_dynar_t sg_platf_AS_begin_cb_list = NULL; //of sg_platf_AS_begin_cb_t xbt_dynar_t sg_platf_AS_end_cb_list = NULL; //of void_f_void_t xbt_dynar_t sg_platf_postparse_cb_list = NULL; // of void_f_void_t @@ -28,6 +29,7 @@ void sg_platf_init(void) { sg_platf_router_cb_list = xbt_dynar_new(sizeof(sg_platf_host_cb_t), NULL); sg_platf_link_cb_list = xbt_dynar_new(sizeof(sg_platf_host_cb_t), NULL); sg_platf_peer_cb_list = xbt_dynar_new(sizeof(sg_platf_peer_cb_t), NULL); + sg_platf_cluster_cb_list = xbt_dynar_new(sizeof(sg_platf_cluster_cb_t), NULL); sg_platf_postparse_cb_list = xbt_dynar_new(sizeof(sg_platf_link_cb_t),NULL); sg_platf_AS_begin_cb_list = xbt_dynar_new(sizeof(sg_platf_AS_begin_cb_t),NULL); sg_platf_AS_end_cb_list = xbt_dynar_new(sizeof(void_f_void_t),NULL); @@ -39,6 +41,7 @@ void sg_platf_exit(void) { xbt_dynar_free(&sg_platf_link_cb_list); xbt_dynar_free(&sg_platf_postparse_cb_list); xbt_dynar_free(&sg_platf_peer_cb_list); + xbt_dynar_free(&sg_platf_cluster_cb_list); xbt_dynar_free(&sg_platf_AS_begin_cb_list); xbt_dynar_free(&sg_platf_AS_end_cb_list); @@ -70,10 +73,17 @@ void sg_platf_new_link(sg_platf_link_cbarg_t link){ void sg_platf_new_peer(sg_platf_peer_cbarg_t peer){ unsigned int iterator; sg_platf_peer_cb_t fun; - xbt_dynar_foreach(sg_platf_link_cb_list, iterator, fun) { + xbt_dynar_foreach(sg_platf_peer_cb_list, iterator, fun) { fun(peer); } } +void sg_platf_new_cluster(sg_platf_cluster_cbarg_t cluster){ + unsigned int iterator; + sg_platf_cluster_cb_t fun; + xbt_dynar_foreach(sg_platf_cluster_cb_list, iterator, fun) { + fun(cluster); + } +} void sg_platf_begin() { /* Do nothing: just for symmetry of user code */ } @@ -91,7 +101,7 @@ void sg_platf_new_AS_begin(const char *id, const char *routing) { unsigned int iterator; sg_platf_AS_begin_cb_t fun; - if (!surf_parse_models_setup_already_called && xbt_dynar_length(sg_platf_AS_begin_cb_list)) { + if (!surf_parse_models_setup_already_called && !xbt_dynar_is_empty(sg_platf_AS_begin_cb_list)) { /* Initialize the surf models. That must be done after we got all config, and before we need the models. * That is, after the last tag, if any, and before the first of cluster|peer|AS|trace|trace_connect * @@ -134,6 +144,9 @@ void sg_platf_router_add_cb(sg_platf_router_cb_t fct) { void sg_platf_peer_add_cb(sg_platf_peer_cb_t fct) { xbt_dynar_push(sg_platf_peer_cb_list, &fct); } +void sg_platf_cluster_add_cb(sg_platf_cluster_cb_t fct) { + xbt_dynar_push(sg_platf_cluster_cb_list, &fct); +} void sg_platf_postparse_add_cb(void_f_void_t fct) { xbt_dynar_push(sg_platf_postparse_cb_list, &fct); }