X-Git-Url: https://git.liburcu.org/?a=blobdiff_plain;f=urcu-bp.c;h=b07a1bbed912a5998c1089a2237825d2801f7032;hb=852a17ad88c691a96a67754bce91826b33877812;hp=67eae07b6e1b3f69c9cc4739d524dd45de899daf;hpb=424d4ed5e7b0ca5e05c3078f15abf473c6879521;p=urcu.git diff --git a/urcu-bp.c b/urcu-bp.c index 67eae07..b07a1bb 100644 --- a/urcu-bp.c +++ b/urcu-bp.c @@ -36,12 +36,14 @@ #include #include -#include "urcu/wfqueue.h" +#include "urcu/wfcqueue.h" #include "urcu/map/urcu-bp.h" #include "urcu/static/urcu-bp.h" #include "urcu-pointer.h" #include "urcu/tls-compat.h" +#include "urcu-die.h" + /* Do not #define _LGPL_SOURCE to ensure we can emit the wrapper symbols */ #undef _LGPL_SOURCE #include "urcu-bp.h" @@ -103,8 +105,8 @@ void __attribute__((destructor)) rcu_bp_exit(void); static pthread_mutex_t rcu_gp_lock = PTHREAD_MUTEX_INITIALIZER; #ifdef DEBUG_YIELD -unsigned int yield_active; -DEFINE_URCU_TLS(unsigned int, rand_yield); +unsigned int rcu_yield_active; +DEFINE_URCU_TLS(unsigned int, rcu_rand_yield); #endif /* @@ -142,17 +144,12 @@ static void mutex_lock(pthread_mutex_t *mutex) #ifndef DISTRUST_SIGNALS_EXTREME ret = pthread_mutex_lock(mutex); - if (ret) { - perror("Error in pthread mutex lock"); - exit(-1); - } + if (ret) + urcu_die(ret); #else /* #ifndef DISTRUST_SIGNALS_EXTREME */ while ((ret = pthread_mutex_trylock(mutex)) != 0) { - if (ret != EBUSY && ret != EINTR) { - printf("ret = %d, errno = %d\n", ret, errno); - perror("Error in pthread mutex lock"); - exit(-1); - } + if (ret != EBUSY && ret != EINTR) + urcu_die(ret); poll(NULL,0,10); } #endif /* #else #ifndef DISTRUST_SIGNALS_EXTREME */ @@ -163,13 +160,11 @@ static void mutex_unlock(pthread_mutex_t *mutex) int ret; ret = pthread_mutex_unlock(mutex); - if (ret) { - perror("Error in pthread mutex unlock"); - exit(-1); - } + if (ret) + urcu_die(ret); } -void update_counter_and_wait(void) +static void update_counter_and_wait(void) { CDS_LIST_HEAD(qsreaders); int wait_loops = 0;