X-Git-Url: http://git.liburcu.org/?p=urcu.git;a=blobdiff_plain;f=urcu.c;h=07537efbc55c90943b49f1a240aab5935fc55bc7;hp=c07df2e8cf21384a07da3bb47066cd2b2bb44084;hb=ed868fa15f8c5511a1c32d1779f6fe37375c7137;hpb=c297c21c6eadc359a358d33e65f9f5419b55b586 diff --git a/urcu.c b/urcu.c index c07df2e..07537ef 100644 --- a/urcu.c +++ b/urcu.c @@ -36,11 +36,11 @@ /* Do not #define _LGPL_SOURCE to ensure we can emit the wrapper symbols */ #include "urcu.h" -#ifndef DEBUG_FULL_MB +#ifndef URCU_MB void __attribute__((constructor)) urcu_init(void); void __attribute__((destructor)) urcu_exit(void); #else -static inline urcu_init(void) +void urcu_init(void) { } #endif @@ -52,7 +52,7 @@ pthread_mutex_t urcu_mutex = PTHREAD_MUTEX_INITIALIZER; /* * Global grace period counter. * Contains the current RCU_GP_CTR_BIT. - * Also has a RCU_GP_CTR_BIT of 1, to accelerate the reader fast path. + * Also has a RCU_GP_COUNT of 1, to accelerate the reader fast path. * Written to only by writer with mutex taken. Read by both writer and readers. */ long urcu_gp_ctr = RCU_GP_COUNT; @@ -127,7 +127,7 @@ static void switch_next_urcu_qparity(void) STORE_SHARED(urcu_gp_ctr, urcu_gp_ctr ^ RCU_GP_CTR_BIT); } -#ifdef DEBUG_FULL_MB +#ifdef URCU_MB #ifdef HAS_INCOHERENT_CACHES static void force_mb_single_thread(struct reader_registry *index) { @@ -139,7 +139,7 @@ static void force_mb_all_threads(void) { smp_mb(); } -#else /* #ifdef DEBUG_FULL_MB */ +#else /* #ifdef URCU_MB */ #ifdef HAS_INCOHERENT_CACHES static void force_mb_single_thread(struct reader_registry *index) { @@ -206,7 +206,7 @@ static void force_mb_all_threads(void) } smp_mb(); /* read ->need_mb before ending the barrier */ } -#endif /* #else #ifdef DEBUG_FULL_MB */ +#endif /* #else #ifdef URCU_MB */ void wait_for_quiescent_state(void) { @@ -420,7 +420,7 @@ void rcu_unregister_thread(void) internal_urcu_unlock(); } -#ifndef DEBUG_FULL_MB +#ifndef URCU_MB static void sigurcu_handler(int signo, siginfo_t *siginfo, void *context) { /* @@ -451,7 +451,7 @@ void urcu_init(void) init_done = 1; act.sa_sigaction = sigurcu_handler; - act.sa_flags = SA_SIGINFO; + act.sa_flags = SA_SIGINFO | SA_RESTART; sigemptyset(&act.sa_mask); ret = sigaction(SIGURCU, &act, NULL); if (ret) { @@ -473,4 +473,4 @@ void urcu_exit(void) assert(act.sa_sigaction == sigurcu_handler); free(registry); } -#endif /* #ifndef DEBUG_FULL_MB */ +#endif /* #ifndef URCU_MB */