X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/b4c416b8b1a5cf0b3f4e6220303548d673603385..1c6ecd7825422241dd932318a4ba03c3df1de985:/src/simix/smx_global.c diff --git a/src/simix/smx_global.c b/src/simix/smx_global.c index abc2281e7b..2a3a403798 100644 --- a/src/simix/smx_global.c +++ b/src/simix/smx_global.c @@ -43,7 +43,7 @@ static void _XBT_CALL inthandler(int ignored) SIMIX_display_process_status(); } else { - XBT_INFO("CTRL-C pressed. bailing out without displaying because verbose-exit disabled"); + XBT_INFO("CTRL-C pressed. bailing out without displaying because verbose-exit is disabled"); } exit(1); } @@ -86,7 +86,7 @@ void SIMIX_global_init(int *argc, char **argv) xbt_swag_new(xbt_swag_offset(proc, destroy_hookup)); simix_global->maestro_process = NULL; - simix_global->registered_functions = xbt_dict_new(); + simix_global->registered_functions = xbt_dict_new_homogeneous(NULL); simix_global->create_process_function = SIMIX_process_create; simix_global->kill_process_function = SIMIX_process_kill; @@ -135,6 +135,7 @@ void SIMIX_clean(void) SIMIX_network_exit(); xbt_heap_free(simix_timers); + simix_timers = NULL; /* Free the remaining data structures */ xbt_dynar_free(&simix_global->process_to_run); xbt_dynar_free(&simix_global->process_that_ran); @@ -197,19 +198,20 @@ void SIMIX_run(void) #ifdef TIME_BENCH smx_ctx_raw_new_sr(); #endif - while (xbt_dynar_length(simix_global->process_to_run)) { + while (!xbt_dynar_is_empty(simix_global->process_to_run)) { XBT_DEBUG("New Sub-Schedule Round; size(queue)=%lu", xbt_dynar_length(simix_global->process_to_run)); SIMIX_process_runall(); xbt_dynar_foreach(simix_global->process_that_ran, iter, process) { if (process->request.call != REQ_NO_REQ) { - XBT_DEBUG("Handling request %p", &process->request); SIMIX_request_pre(&process->request, 0); } } } - time = surf_solve(SIMIX_timer_next()); + time = SIMIX_timer_next(); + if (time != -1.0 || xbt_swag_size(simix_global->process_list) != 0) + time = surf_solve(time); /* Notify all the hosts that have failed */ /* FIXME: iterate through the list of failed host and mark each of them */ @@ -238,7 +240,7 @@ void SIMIX_run(void) /* Clean processes to destroy */ SIMIX_process_empty_trash(); - } while (time != -1.0); + } while (time != -1.0 || !xbt_dynar_is_empty(simix_global->process_to_run)); if (xbt_swag_size(simix_global->process_list) != 0) { @@ -326,7 +328,7 @@ void SIMIX_display_process_status(void) XBT_INFO("%d processes are still running, waiting for something.", nbprocess); /* List the process and their state */ XBT_INFO - ("Legend of the following listing: \"() on : .\""); + ("Legend of the following listing: \"Process (@): \""); xbt_swag_foreach(process, simix_global->process_list) { if (process->waiting_action) { @@ -358,8 +360,13 @@ void SIMIX_display_process_status(void) action_description = "I/O"; break; } - XBT_INFO("Process %ld (%s@%s): waiting for %s action %p (%s) to finish", process->pid, process->name, process->smx_host->name, - action_description, process->waiting_action, process->waiting_action->name); + XBT_INFO("Process %ld (%s@%s): waiting for %s action %p (%s) in state %d to finish", + process->pid, process->name, process->smx_host->name, + action_description, process->waiting_action, + process->waiting_action->name, process->waiting_action->state); + } + else { + XBT_INFO("Process %ld (%s@%s)", process->pid, process->name, process->smx_host->name); } } }