X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/30f1c8c5e4b8a7b6e593c7bb885ffad766ae6f5d..b3ca3a517af21780e88cc89869b16927d1fea68a:/src/simix/smx_context_thread.c diff --git a/src/simix/smx_context_thread.c b/src/simix/smx_context_thread.c index e3fbcf0f4b..fbde818409 100644 --- a/src/simix/smx_context_thread.c +++ b/src/simix/smx_context_thread.c @@ -1,18 +1,17 @@ /* context_thread - implementation of context switching with native threads */ -/* Copyright (c) 2009, 2010. The SimGrid Team. +/* Copyright (c) 2009-2014. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ #include "xbt/function_types.h" -#include "private.h" +#include "smx_private.h" #include "portable.h" /* loads context system definitions */ #include "xbt/swag.h" #include "xbt/xbt_os_thread.h" #include "xbt_modinter.h" /* prototype of os thread module's init/exit in XBT */ -#include "simix/context.h" XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(simix_context); @@ -26,15 +25,14 @@ typedef struct s_smx_ctx_thread { static xbt_os_sem_t smx_ctx_thread_sem; static smx_context_t -smx_ctx_thread_factory_create_context(xbt_main_func_t code, int argc, - char **argv, +smx_ctx_thread_factory_create_context(xbt_main_func_t code, + int argc, char **argv, void_pfn_smxprocess_t cleanup_func, - void *data); + smx_process_t process); static void smx_ctx_thread_free(smx_context_t context); static void smx_ctx_thread_stop(smx_context_t context); static void smx_ctx_thread_suspend(smx_context_t context); -static void smx_ctx_thread_resume(smx_context_t new_context); static void smx_ctx_thread_runall_serial(void); static void smx_ctx_thread_runall_parallel(void); static smx_context_t smx_ctx_thread_self(void); @@ -82,24 +80,30 @@ static smx_context_t smx_ctx_thread_factory_create_context(xbt_main_func_t code, int argc, char **argv, void_pfn_smxprocess_t cleanup_func, - void *data) + smx_process_t process) { smx_ctx_thread_t context = (smx_ctx_thread_t) smx_ctx_base_factory_create_context_sized(sizeof(s_smx_ctx_thread_t), code, argc, argv, - cleanup_func, data); + cleanup_func, process); /* If the user provided a function for the process then use it otherwise is the context for maestro */ if (code) { context->begin = xbt_os_sem_init(0); context->end = xbt_os_sem_init(0); + if (smx_context_stack_size_was_set) + xbt_os_thread_setstacksize(smx_context_stack_size); + if (smx_context_guard_size_was_set) + xbt_os_thread_setguardsize(smx_context_guard_size); + /* create and start the process */ /* NOTE: The first argument to xbt_os_thread_create used to be the process * * name, but now the name is stored at SIMIX level, so we pass a null */ context->thread = xbt_os_thread_create(NULL, smx_ctx_thread_wrapper, context, context); + /* wait the starting of the newly created process */ xbt_os_sem_acquire(context->end); @@ -114,7 +118,7 @@ static void smx_ctx_thread_free(smx_context_t pcontext) { smx_ctx_thread_t context = (smx_ctx_thread_t) pcontext; - /* check if this is the context of maestro (it doesn't has a real thread) */ + /* check if this is the context of maestro (it doesn't have a real thread) */ if (context->thread) { /* wait about the thread terminason */ xbt_os_thread_join(context->thread, NULL); @@ -148,7 +152,14 @@ static void smx_ctx_thread_stop(smx_context_t pcontext) static void *smx_ctx_thread_wrapper(void *param) { smx_ctx_thread_t context = (smx_ctx_thread_t) param; - +#ifndef WIN32 + /* Install alternate signal stack, for SIGSEGV handler. */ + stack_t stack; + stack.ss_sp = sigsegv_stack; + stack.ss_size = sizeof sigsegv_stack; + stack.ss_flags = 0; + sigaltstack(&stack, NULL); +#endif /* Tell the maestro we are starting, and wait for its green light */ xbt_os_sem_release(context->end); xbt_os_sem_acquire(context->begin);