X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/07c319ec54d6fc778ee3cc5e75a747242006723e..9a444de20a7545d1c3d10bd242f317febded25c4:/src/xbt/xbt_sg_synchro.c diff --git a/src/xbt/xbt_sg_synchro.c b/src/xbt/xbt_sg_synchro.c index 7c6bc74a51..34d22444b0 100644 --- a/src/xbt/xbt_sg_synchro.c +++ b/src/xbt/xbt_sg_synchro.c @@ -37,8 +37,8 @@ typedef struct s_xbt_thread_ { static int xbt_thread_create_wrapper(int argc, char *argv[]) { xbt_thread_t t = - (xbt_thread_t) SIMIX_process_get_data(SIMIX_process_self()); - SIMIX_process_set_data(SIMIX_process_self(), t->father_data); + (xbt_thread_t) SIMIX_process_self_get_data(); + SIMIX_req_process_set_data(SIMIX_process_self(), t->father_data); (*t->code) (t->userparam); if (t->joinable) { t->done = 1; @@ -61,12 +61,12 @@ xbt_thread_t xbt_thread_create(const char *name, void_f_pvoid_t code, res->name = xbt_strdup(name); res->userparam = param; res->code = code; - res->father_data = SIMIX_process_get_data(SIMIX_process_self()); + res->father_data = SIMIX_process_self_get_data(); /* char*name = bprintf("%s#%p",SIMIX_process_self_get_name(), param); */ - res->s_process = SIMIX_process_create(name, - xbt_thread_create_wrapper, res, - SIMIX_host_self_get_name(), 0, NULL, - /*props */ NULL); + SIMIX_req_process_create(&res->s_process, name, + xbt_thread_create_wrapper, res, + SIMIX_host_self_get_name(), 0, NULL, + /*props */ NULL); res->joinable = joinable; res->done = 0; res->cond = xbt_cond_init(); @@ -90,7 +90,7 @@ const char *xbt_thread_self_name(void) void xbt_thread_join(xbt_thread_t thread) { xbt_mutex_acquire(thread->mutex); - xbt_assert1(thread->joinable, + xbt_assert(thread->joinable, "Cannot join on %p: wasn't created joinable", thread); if (!thread->done) { xbt_cond_wait(thread->cond, thread->mutex); @@ -106,20 +106,19 @@ void xbt_thread_join(xbt_thread_t thread) void xbt_thread_cancel(xbt_thread_t thread) { - SIMIX_process_kill(thread->s_process, SIMIX_process_self()); + SIMIX_req_process_kill(thread->s_process); free(thread->name); free(thread); } void xbt_thread_exit() { - SIMIX_process_kill(SIMIX_process_self(), SIMIX_process_self()); + SIMIX_req_process_kill(SIMIX_process_self()); } xbt_thread_t xbt_thread_self(void) { - smx_process_t p = SIMIX_process_self(); - return p ? SIMIX_process_get_data(p) : NULL; + return SIMIX_process_self_get_data(); } void xbt_thread_yield(void)