X-Git-Url: http://git.liburcu.org/?a=blobdiff_plain;f=urcu-qsbr.c;h=3f21be3160731979b6f39455b1202ccf00849237;hb=8f50d1ce191ad5f85384c0afbf1ac5b7516ea79f;hp=b387536adc6ef923d8254934b41955389002f0fc;hpb=4e27f05811113a4444d142811d38e77bcbabbf04;p=urcu.git diff --git a/urcu-qsbr.c b/urcu-qsbr.c index b387536..3f21be3 100644 --- a/urcu-qsbr.c +++ b/urcu-qsbr.c @@ -106,11 +106,6 @@ static void force_mb_single_thread(struct reader_registry *index) } #endif /* #ifdef HAS_INCOHERENT_CACHES */ -static void force_mb_all_threads(void) -{ - smp_mb(); -} - static void wait_for_quiescent_state(void) { struct reader_registry *index; @@ -153,18 +148,18 @@ void synchronize_rcu(void) * our own quiescent state. This allows using synchronize_rcu() in * threads registered as readers. */ + smp_mb(); if (was_online) - _rcu_thread_offline(); + STORE_SHARED(rcu_reader_qs_gp, 0); - force_mb_all_threads(); internal_urcu_lock(); STORE_SHARED(urcu_gp_ctr, urcu_gp_ctr + 2); wait_for_quiescent_state(); internal_urcu_unlock(); - force_mb_all_threads(); if (was_online) - _rcu_thread_online(); + _STORE_SHARED(rcu_reader_qs_gp, LOAD_SHARED(urcu_gp_ctr) + 1); + smp_mb(); } /*