X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/273f840b0cbfdf3ce198781ad3c7ea195eac7135..7e71d73eb6728d8d498d010976f038789049c131:/src/simix/smx_context_thread.c?ds=inline diff --git a/src/simix/smx_context_thread.c b/src/simix/smx_context_thread.c index 6ffe15719e..30c66538fc 100644 --- a/src/simix/smx_context_thread.c +++ b/src/simix/smx_context_thread.c @@ -29,13 +29,8 @@ smx_ctx_thread_factory_create_context(xbt_main_func_t code, int argc, char** arg void_f_pvoid_t cleanup_func, void* cleanup_arg); static int smx_ctx_thread_factory_finalize(smx_context_factory_t * factory); - static void smx_ctx_thread_free(smx_context_t context); - -static void smx_ctx_thread_start(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 @@ -80,6 +75,16 @@ smx_ctx_thread_factory_create_context(xbt_main_func_t code, int argc, char** arg context->cleanup_arg = cleanup_arg; context->begin = xbt_os_sem_init(0); context->end = xbt_os_sem_init(0); + + + /* 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, ctx_thread); + + /* wait the starting of the newly created process */ + xbt_os_sem_acquire(context->end); } return (smx_context_t)context; @@ -113,20 +118,6 @@ static void smx_ctx_thread_free(smx_context_t pcontext) free(context); } -static void smx_ctx_thread_start(smx_context_t context) -{ - smx_ctx_thread_t ctx_thread = (smx_ctx_thread_t)context; - - /* 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 */ - ctx_thread->thread = - xbt_os_thread_create(NULL, smx_ctx_thread_wrapper, ctx_thread); - - /* wait the starting of the newly created process */ - xbt_os_sem_acquire(ctx_thread->end); -} - static void smx_ctx_thread_stop(smx_context_t pcontext) { @@ -169,4 +160,4 @@ static void smx_ctx_thread_resume(smx_context_t not_used, { xbt_os_sem_release(((smx_ctx_thread_t) new_context)->begin); xbt_os_sem_acquire(((smx_ctx_thread_t) new_context)->end); -} \ No newline at end of file +}