X-Git-Url: http://git.liburcu.org/?a=blobdiff_plain;f=urcu-qsbr-static.h;h=22a93b2fd7a823d21c76cbbd1ad5c6bf3b0495e4;hb=2c5e5fb3c4f567af1816aaada4cfbc69a0c1a882;hp=8d8aa3f8f60519620dbcfb78aef1b007c6183e5c;hpb=ab179a1705ee5d662c6a7964645077980096e134;p=urcu.git diff --git a/urcu-qsbr-static.h b/urcu-qsbr-static.h index 8d8aa3f..22a93b2 100644 --- a/urcu-qsbr-static.h +++ b/urcu-qsbr-static.h @@ -32,6 +32,7 @@ #include #include #include +#include #include #include @@ -160,28 +161,43 @@ static inline void reader_barrier() smp_mb(); } +#define RCU_GP_ONLINE (1UL << 0) +#define RCU_GP_CTR (1UL << 1) + /* * Global quiescent period counter with low-order bits unused. * Using a int rather than a char to eliminate false register dependencies * causing stalls on some architectures. */ -extern long urcu_gp_ctr; +extern unsigned long urcu_gp_ctr; + +extern unsigned long __thread rcu_reader_qs_gp; -extern long __thread rcu_reader_qs_gp; +#if (BITS_PER_LONG < 64) +static inline int rcu_gp_ongoing(unsigned long *value) +{ + unsigned long reader_gp; -static inline int rcu_gp_ongoing(long *value) + if (value == NULL) + return 0; + reader_gp = LOAD_SHARED(*value); + return reader_gp && ((reader_gp ^ urcu_gp_ctr) & RCU_GP_CTR); +} +#else /* !(BITS_PER_LONG < 64) */ +static inline int rcu_gp_ongoing(unsigned long *value) { - long reader_gp; + unsigned long reader_gp; if (value == NULL) return 0; reader_gp = LOAD_SHARED(*value); - return reader_gp && (reader_gp - urcu_gp_ctr < 0); + return reader_gp && (reader_gp - urcu_gp_ctr > ULONG_MAX / 2); } +#endif /* !(BITS_PER_LONG < 64) */ static inline void _rcu_read_lock(void) { - rcu_assert(rcu_reader_qs_gp & 1); + rcu_assert(rcu_reader_qs_gp); } static inline void _rcu_read_unlock(void)