X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/b69e984a013e4e9e2d98fc4013cd1721bf2f0245..bea6786798593b78e0d62a2308eacad3284d4537:/src/simix/smx_deployment.c diff --git a/src/simix/smx_deployment.c b/src/simix/smx_deployment.c index 4a2bb97975..2ca297f52f 100644 --- a/src/simix/smx_deployment.c +++ b/src/simix/smx_deployment.c @@ -10,6 +10,7 @@ #include "private.h" #include "xbt/sysdep.h" #include "xbt/log.h" +#include "xbt/dict.h" #include "surf/surfxml_parse_private.h" XBT_LOG_NEW_DEFAULT_SUBCATEGORY(simix_deployment, simix, @@ -24,8 +25,8 @@ static double kill_time = -1.0; static void parse_process_init(void) { parse_host = xbt_strdup(A_surfxml_process_host); - xbt_assert1(SIMIX_host_get_by_name(A_surfxml_process_host), - "Unknown host %s", A_surfxml_process_host); + xbt_assert1(SIMIX_host_get_by_name(parse_host), + "Unknown host %s", parse_host); parse_code = SIMIX_get_registered_function(A_surfxml_process_function); xbt_assert1(parse_code, "Unknown function %s", A_surfxml_process_function); @@ -36,6 +37,8 @@ static void parse_process_init(void) parse_argv[(parse_argc) - 1] = xbt_strdup(A_surfxml_process_function); surf_parse_get_double(&start_time, A_surfxml_process_start_time); surf_parse_get_double(&kill_time, A_surfxml_process_kill_time); + + current_property_set = xbt_dict_new(); } static void parse_argument(void) @@ -58,17 +61,17 @@ static void parse_process_finalize(void) arg->argc = parse_argc; arg->argv = parse_argv; arg->kill_time = kill_time; + arg->properties = current_property_set; DEBUG3("Process %s(%s) will be started at time %f", arg->name, arg->hostname, start_time); if (simix_global->create_process_function) - surf_timer_resource->extension_public->set(start_time, + surf_timer_model->extension_public->set(start_time, (void *) simix_global-> create_process_function, arg); else - surf_timer_resource->extension_public->set(start_time, - (void *) + surf_timer_model->extension_public->set(start_time, (void *) &SIMIX_process_create, arg); @@ -78,23 +81,22 @@ static void parse_process_finalize(void) if (simix_global->create_process_function) process = - simix_global->create_process_function(parse_argv[0], parse_code, + (*simix_global->create_process_function)(parse_argv[0], parse_code, NULL, parse_host, - parse_argc, parse_argv); + parse_argc, parse_argv, /*the props*/ current_property_set); else process = SIMIX_process_create(parse_argv[0], parse_code, NULL, parse_host, - parse_argc, parse_argv); + parse_argc, parse_argv, /*the props*/ current_property_set); if (kill_time > SIMIX_get_clock()) { if (simix_global->kill_process_function) - surf_timer_resource->extension_public->set(start_time, + surf_timer_model->extension_public->set(start_time, (void *) simix_global-> kill_process_function, arg); else - surf_timer_resource->extension_public->set(kill_time, - (void *) + surf_timer_model->extension_public->set(kill_time, (void *) &SIMIX_process_kill, (void *) process); } @@ -120,9 +122,12 @@ void SIMIX_launch_application(const char *file) { xbt_assert0(simix_global, "SIMIX_global_init has to be called before SIMIX_launch_application."); - STag_surfxml_process_fun = parse_process_init; - ETag_surfxml_argument_fun = parse_argument; - ETag_surfxml_process_fun = parse_process_finalize; + surf_parse_reset_parser(); + surfxml_add_callback(STag_surfxml_process_cb_list, parse_process_init); + surfxml_add_callback(ETag_surfxml_argument_cb_list, parse_argument); + surfxml_add_callback(STag_surfxml_prop_cb_list, parse_properties); + surfxml_add_callback(ETag_surfxml_process_cb_list, parse_process_finalize); + surf_parse_open(file); xbt_assert1((!surf_parse()), "Parse error in %s", file); surf_parse_close();