X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/749a6d6656fdc1c02032bec7c6dbc450387d4420..47fb968673db55fee5ab9b7d5dcf395fd47118f1:/src/simix/smx_process.c diff --git a/src/simix/smx_process.c b/src/simix/smx_process.c index b71da54ff0..1444dc0119 100644 --- a/src/simix/smx_process.c +++ b/src/simix/smx_process.c @@ -211,8 +211,9 @@ void SIMIX_pre_process_create(smx_simcall_t simcall, int argc, char **argv, xbt_dict_t properties, int auto_restart){ - SIMIX_process_create(process, name, code, data, hostname, - kill_time, argc, argv, properties, auto_restart); + SIMIX_process_create_with_parent(process, name, code, data, hostname, + kill_time, argc, argv, properties, auto_restart, + simcall->issuer); } /** * \brief Internal function to create a process. @@ -232,7 +233,20 @@ void SIMIX_process_create(smx_process_t *process, int argc, char **argv, xbt_dict_t properties, int auto_restart) { - + SIMIX_process_create_with_parent(process, name, code, data, hostname, + kill_time, argc, argv, properties, auto_restart, NULL); +} + +void SIMIX_process_create_with_parent(smx_process_t *process, + const char *name, + xbt_main_func_t code, + void *data, + const char *hostname, + double kill_time, + int argc, char **argv, + xbt_dict_t properties, + int auto_restart, + smx_process_t parent_process) { *process = NULL; smx_host_t host = SIMIX_host_get_by_name(hostname); @@ -258,8 +272,8 @@ void SIMIX_process_create(smx_process_t *process, (*process)->comms = xbt_fifo_new(); (*process)->simcall.issuer = *process; - if (SIMIX_process_self()) { - (*process)->ppid = SIMIX_process_get_PID(SIMIX_process_self()); + if (parent_process) { + (*process)->ppid = SIMIX_process_get_PID(parent_process); } else { (*process)->ppid = -1; } @@ -722,7 +736,7 @@ void SIMIX_post_process_sleep(smx_action_t action) { smx_simcall_t simcall; e_smx_state_t state; - + smx_process_t issuer; xbt_assert(action->type == SIMIX_ACTION_SLEEP); while ((simcall = xbt_fifo_shift(action->simcalls))) { @@ -748,9 +762,13 @@ void SIMIX_post_process_sleep(smx_action_t action) simcall_process_sleep__set__result(simcall, state); simcall->issuer->waiting_action = NULL; SIMIX_simcall_answer(simcall); + issuer = simcall->issuer; } + SIMIX_process_sleep_destroy(action); + if (issuer->suspended) + simcall_process_suspend(issuer); } void SIMIX_process_sleep_destroy(smx_action_t action)