X-Git-Url: http://git.liburcu.org/?p=urcu.git;a=blobdiff_plain;f=urcu-qsbr.c;h=ba6e02af27f3a18b60f26d56779bb5d4f869524e;hp=1955277ac65d309e8b187f82b2eec242a7d211f2;hb=599dd1cab8011f43e54f2eb613e695281380e5e4;hpb=ab179a1705ee5d662c6a7964645077980096e134 diff --git a/urcu-qsbr.c b/urcu-qsbr.c index 1955277..ba6e02a 100644 --- a/urcu-qsbr.c +++ b/urcu-qsbr.c @@ -42,20 +42,20 @@ pthread_mutex_t urcu_mutex = PTHREAD_MUTEX_INITIALIZER; /* * Global grace period counter. */ -long urcu_gp_ctr = 1; +unsigned long urcu_gp_ctr = RCU_GP_ONLINE; /* * Written to only by each individual reader. Read by both the reader and the * writers. */ -long __thread rcu_reader_qs_gp; +unsigned long __thread rcu_reader_qs_gp; /* Thread IDs of registered readers */ #define INIT_NUM_THREADS 4 struct reader_registry { pthread_t tid; - long *rcu_reader_qs_gp; + unsigned long *rcu_reader_qs_gp; }; #ifdef DEBUG_YIELD @@ -139,7 +139,7 @@ static void wait_for_quiescent_state(void) void synchronize_rcu(void) { - long was_online; + unsigned long was_online; was_online = rcu_reader_qs_gp; @@ -153,7 +153,7 @@ void synchronize_rcu(void) STORE_SHARED(rcu_reader_qs_gp, 0); internal_urcu_lock(); - STORE_SHARED(urcu_gp_ctr, urcu_gp_ctr + 2); + STORE_SHARED(urcu_gp_ctr, urcu_gp_ctr + RCU_GP_CTR); wait_for_quiescent_state(); internal_urcu_unlock();