X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/10cf0994b175d422edd693db91f25a96418b6862..b62e431af6ffa480a59647aad94ffe0d292c05a8:/src/xbt/xbt_os_synchro.c diff --git a/src/xbt/xbt_os_synchro.c b/src/xbt/xbt_os_synchro.c index 22a4908db4..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 */ @@ -72,44 +72,3 @@ void xbt_cond_destroy(xbt_cond_t cond) { SIMIX_cond_unref((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); -}