From 78ff941908d1c336106c06649c0892015cc98e18 Mon Sep 17 00:00:00 2001 From: Mathieu Desnoyers Date: Wed, 13 Jan 2010 11:37:14 -0500 Subject: [PATCH] signal-based urcu: rename force_mb_all_threads -> force_mb_all_readers Signed-off-by: Mathieu Desnoyers --- urcu-static.h | 4 ++-- urcu.c | 18 +++++++++--------- 2 files changed, 11 insertions(+), 11 deletions(-) diff --git a/urcu-static.h b/urcu-static.h index bd11be8..0708df7 100644 --- a/urcu-static.h +++ b/urcu-static.h @@ -216,7 +216,7 @@ static inline void _rcu_read_lock(void) _STORE_SHARED(rcu_reader.ctr, _LOAD_SHARED(rcu_gp_ctr)); /* * Set active readers count for outermost nesting level before - * accessing the pointer. See force_mb_all_threads(). + * accessing the pointer. See force_mb_all_readers(). */ reader_barrier(); } else { @@ -231,7 +231,7 @@ static inline void _rcu_read_unlock(void) tmp = rcu_reader.ctr; /* * Finish using rcu before decrementing the pointer. - * See force_mb_all_threads(). + * See force_mb_all_readers(). */ if (likely((tmp & RCU_GP_CTR_NEST_MASK) == RCU_GP_COUNT)) { reader_barrier(); diff --git a/urcu.c b/urcu.c index c4b2b42..3132e59 100644 --- a/urcu.c +++ b/urcu.c @@ -126,7 +126,7 @@ static void force_mb_single_thread(struct rcu_reader *index) } #endif //0 -static void force_mb_all_threads(void) +static void force_mb_all_readers(void) { smp_mb(); } @@ -156,7 +156,7 @@ static void force_mb_single_thread(struct rcu_reader *index) } #endif //0 -static void force_mb_all_threads(void) +static void force_mb_all_readers(void) { struct rcu_reader *index; @@ -206,7 +206,7 @@ static void force_mb_all_threads(void) static void wait_gp(void) { /* Read reader_gp before read futex */ - force_mb_all_threads(); + force_mb_all_readers(); if (uatomic_read(&gp_futex) == -1) futex_async(&gp_futex, FUTEX_WAIT, -1, NULL, NULL, 0); @@ -228,7 +228,7 @@ void wait_for_quiescent_state(void) if (wait_loops == RCU_QS_ACTIVE_ATTEMPTS) { uatomic_dec(&gp_futex); /* Write futex before read reader_gp */ - force_mb_all_threads(); + force_mb_all_readers(); } list_for_each_entry_safe(index, tmp, ®istry, head) { @@ -240,7 +240,7 @@ void wait_for_quiescent_state(void) if (list_empty(®istry)) { if (wait_loops == RCU_QS_ACTIVE_ATTEMPTS) { /* Read reader_gp before write futex */ - force_mb_all_threads(); + force_mb_all_readers(); uatomic_set(&gp_futex, 0); } break; @@ -258,7 +258,7 @@ void wait_for_quiescent_state(void) if (list_empty(®istry)) { if (wait_loops == RCU_QS_ACTIVE_ATTEMPTS) { /* Read reader_gp before write futex */ - force_mb_all_threads(); + force_mb_all_readers(); uatomic_set(&gp_futex, 0); } break; @@ -268,7 +268,7 @@ void wait_for_quiescent_state(void) wait_gp(); break; /* only escape switch */ case KICK_READER_LOOPS: - force_mb_all_threads(); + force_mb_all_readers(); wait_loops = 0; break; /* only escape switch */ default: @@ -289,7 +289,7 @@ void synchronize_rcu(void) * where new ptr points to. Must be done within internal_rcu_lock * because it iterates on reader threads.*/ /* Write new ptr before changing the qparity */ - force_mb_all_threads(); + force_mb_all_readers(); switch_next_rcu_qparity(); /* 0 -> 1 */ @@ -353,7 +353,7 @@ void synchronize_rcu(void) /* Finish waiting for reader threads before letting the old ptr being * freed. Must be done within internal_rcu_lock because it iterates on * reader threads. */ - force_mb_all_threads(); + force_mb_all_readers(); internal_rcu_unlock(); } -- 2.34.1