X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/104db8990fcd552633e6f08ccd9568f26299d0cb..4a69abcc786d029bd2962537f767d12a0f808d11:/src/xbt/xbt_os_synchro.c diff --git a/src/xbt/xbt_os_synchro.c b/src/xbt/xbt_os_synchro.c index 52b1762a1c..8727228800 100644 --- a/src/xbt/xbt_os_synchro.c +++ b/src/xbt/xbt_os_synchro.c @@ -10,7 +10,7 @@ * under the terms of the license (GNU LGPL) which comes with this package. */ #include "xbt/ex.h" -#include "xbt/synchro_core.h" +#include "xbt/synchro.h" #include "simgrid/simix.h" /* used implementation */ @@ -39,7 +39,7 @@ void xbt_mutex_release(xbt_mutex_t mutex) void xbt_mutex_destroy(xbt_mutex_t mutex) { - SIMIX_mutex_destroy((smx_mutex_t) mutex); + SIMIX_mutex_unref((smx_mutex_t) mutex); } /***** condition related functions *****/ @@ -70,46 +70,5 @@ void xbt_cond_broadcast(xbt_cond_t cond) void xbt_cond_destroy(xbt_cond_t cond) { - SIMIX_cond_destroy((smx_cond_t) cond); -} - -/***** barrier related functions *****/ -typedef struct s_xbt_bar_ { - xbt_mutex_t mutex; - xbt_cond_t cond; - unsigned int arrived_processes; - unsigned int expected_processes; -} s_xbt_bar_; - -xbt_bar_t xbt_barrier_init(unsigned int count) -{ - xbt_bar_t bar = xbt_new0(s_xbt_bar_, 1); - bar->expected_processes = count; - bar->arrived_processes = 0; - bar->mutex = xbt_mutex_init(); - bar->cond = xbt_cond_init(); - return bar; -} - -int xbt_barrier_wait(xbt_bar_t bar) -{ - int ret=0; - xbt_mutex_acquire(bar->mutex); - if (++bar->arrived_processes == bar->expected_processes) { - xbt_cond_broadcast(bar->cond); - xbt_mutex_release(bar->mutex); - ret=XBT_BARRIER_SERIAL_PROCESS; - bar->arrived_processes = 0; - } else { - xbt_cond_wait(bar->cond, bar->mutex); - xbt_mutex_release(bar->mutex); - } - return ret; -} - -void xbt_barrier_destroy(xbt_bar_t bar) -{ - xbt_mutex_destroy(bar->mutex); - xbt_cond_destroy(bar->cond); - xbt_free(bar); + SIMIX_cond_unref((smx_cond_t) cond); }