X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/7ca4c132b1f3a64287b8c1cc0c8f9822fa761616..23f5bf52cc58cf837840f231cf638e9fcd45097b:/src/simix/smx_context_sysv.c diff --git a/src/simix/smx_context_sysv.c b/src/simix/smx_context_sysv.c index b292db75d3..9764af2660 100644 --- a/src/simix/smx_context_sysv.c +++ b/src/simix/smx_context_sysv.c @@ -12,6 +12,13 @@ #include "smx_private.h" #include "gras_config.h" #include "context_sysv_config.h" /* loads context system definitions */ +#include "mc/mc.h" + +#ifdef _XBT_WIN32 +# include /* context relative declarations */ +#else +# include /* context relative declarations */ +#endif #ifdef HAVE_VALGRIND_VALGRIND_H # include @@ -19,6 +26,15 @@ XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(simix_context); +typedef struct s_smx_ctx_sysv { + s_smx_ctx_base_t super; /* Fields of super implementation */ + ucontext_t uc; /* the ucontext that executes the code */ +#ifdef HAVE_VALGRIND_VALGRIND_H + unsigned int valgrind_stack_id; /* the valgrind stack id */ +#endif + char stack[0]; /* the thread stack (must remain the last element of the structure) */ +} s_smx_ctx_sysv_t, *smx_ctx_sysv_t; + #ifdef CONTEXT_THREADS static xbt_parmap_t sysv_parmap; static ucontext_t* sysv_workers_stacks; /* space to save the worker's stack in each thread */ @@ -152,6 +168,9 @@ smx_ctx_sysv_create_context_sized(size_t size, xbt_main_func_t code, sysv_maestro_context = context; } + if(MC_is_active() && code) + MC_new_stack_area(context, ((smx_process_t)((smx_context_t)context)->data)->name, &(context->uc), size); + return (smx_context_t) context; } @@ -213,6 +232,11 @@ static void smx_ctx_sysv_suspend_serial(smx_context_t context) smx_context_t next_context; unsigned long int i = sysv_process_index++; + if(MC_is_active()){ + MC_ignore_stack("next_context", "smx_ctx_sysv_suspend_serial"); + MC_ignore_stack("i", "smx_ctx_sysv_suspend_serial"); + } + if (i < xbt_dynar_length(simix_global->process_to_run)) { /* execute the next process */ XBT_DEBUG("Run next process"); @@ -239,14 +263,12 @@ static void smx_ctx_sysv_resume_serial(smx_process_t first_process) static void smx_ctx_sysv_runall_serial(void) { - if (!xbt_dynar_is_empty(simix_global->process_to_run)) { - smx_process_t first_process = - xbt_dynar_get_as(simix_global->process_to_run, 0, smx_process_t); - sysv_process_index = 1; + smx_process_t first_process = + xbt_dynar_get_as(simix_global->process_to_run, 0, smx_process_t); + sysv_process_index = 1; - /* execute the first process */ - smx_ctx_sysv_resume_serial(first_process); - } + /* execute the first process */ + smx_ctx_sysv_resume_serial(first_process); } static void smx_ctx_sysv_stop_parallel(smx_context_t context)