X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/de7d161240f434a809ae7739fbb15a1db6ab86f2..567811b89be3e615ab755f6d5edf437b6b5daf42:/src/simix/smx_context_ruby.c diff --git a/src/simix/smx_context_ruby.c b/src/simix/smx_context_ruby.c index 295accd9cd..4051badd6e 100644 --- a/src/simix/smx_context_ruby.c +++ b/src/simix/smx_context_ruby.c @@ -23,7 +23,7 @@ smx_ctx_ruby_create_context(xbt_main_func_t code, int argc, char **argv, static void smx_ctx_ruby_stop(smx_context_t context); static void smx_ctx_ruby_suspend(smx_context_t context); static void smx_ctx_ruby_resume(smx_context_t new_context); -static void smx_ctx_ruby_runall(xbt_swag_t processes); +static void smx_ctx_ruby_runall(xbt_dynar_t processes); void SIMIX_ctx_ruby_factory_init(smx_context_factory_t * factory) { @@ -71,7 +71,7 @@ static void smx_ctx_ruby_stop(smx_context_t context) ctx_ruby = (smx_ctx_ruby_t) context; - if (((smx_process_t)smx_current_context->data)->iwannadie) { + if (smx_current_context->iwannadie) { if (ctx_ruby->process) { //if the Ruby Process still Alive ,let's Schedule it @@ -110,14 +110,17 @@ static void smx_ctx_ruby_resume(smx_context_t new_context) rb_process_schedule(ctx_ruby->process); } -static void smx_ctx_ruby_runall(xbt_swag_t processes) +static void smx_ctx_ruby_runall(xbt_dynar_t processes) { smx_process_t process; smx_context_t old_context; - while ((process = xbt_swag_extract(processes))) { + unsigned int cursor; + + xbt_dynar_foreach(processes, cursor, process) { old_context = smx_current_context; smx_current_context = process->context; smx_ctx_ruby_resume(smx_current_context); smx_current_context = old_context; - } + } + xbt_dynar_reset(processes); }