#include <errno.h>
#include <poll.h>
+#include "urcu/arch.h"
#include "urcu/wfcqueue.h"
#include "urcu/map/urcu.h"
#include "urcu/static/urcu.h"
*/
#define RCU_QS_ACTIVE_ATTEMPTS 100
-/*
- * RCU_MEMBARRIER is only possibly available on Linux.
- */
-#if defined(RCU_MEMBARRIER) && defined(__linux__)
-#include <urcu/syscall-compat.h>
-#endif
-
-/* If the headers do not support SYS_membarrier, fall back on RCU_MB */
-#ifdef SYS_membarrier
-# define membarrier(...) syscall(SYS_membarrier, __VA_ARGS__)
+/* If the headers do not support membarrier system call, fall back on RCU_MB */
+#ifdef __NR_membarrier
+# define membarrier(...) syscall(__NR_membarrier, __VA_ARGS__)
#else
# define membarrier(...) -ENOSYS
#endif
}
#ifdef RCU_MEMBARRIER
-static void smp_mb_master(int group)
+static void smp_mb_master(void)
{
if (caa_likely(rcu_has_sys_membarrier))
(void) membarrier(MEMBARRIER_CMD_SHARED, 0);
#endif
#ifdef RCU_MB
-static void smp_mb_master(int group)
+static void smp_mb_master(void)
{
cmm_smp_mb();
}
cmm_smp_mb(); /* read ->need_mb before ending the barrier */
}
-static void smp_mb_master(int group)
+static void smp_mb_master(void)
{
force_mb_all_readers();
}
static void wait_gp(void)
{
/* Read reader_gp before read futex */
- smp_mb_master(RCU_MB_GROUP);
+ smp_mb_master();
if (uatomic_read(&rcu_gp.futex) != -1)
return;
while (futex_async(&rcu_gp.futex, FUTEX_WAIT, -1,
if (wait_loops >= RCU_QS_ACTIVE_ATTEMPTS) {
uatomic_dec(&rcu_gp.futex);
/* Write futex before read reader_gp */
- smp_mb_master(RCU_MB_GROUP);
+ smp_mb_master();
}
cds_list_for_each_entry_safe(index, tmp, input_readers, node) {
if (cds_list_empty(input_readers)) {
if (wait_loops >= RCU_QS_ACTIVE_ATTEMPTS) {
/* Read reader_gp before write futex */
- smp_mb_master(RCU_MB_GROUP);
+ smp_mb_master();
uatomic_set(&rcu_gp.futex, 0);
}
break;
if (cds_list_empty(input_readers)) {
if (wait_loops >= RCU_QS_ACTIVE_ATTEMPTS) {
/* Read reader_gp before write futex */
- smp_mb_master(RCU_MB_GROUP);
+ smp_mb_master();
uatomic_set(&rcu_gp.futex, 0);
}
break;
} else {
if (wait_gp_loops == KICK_READER_LOOPS) {
- smp_mb_master(RCU_MB_GROUP);
+ smp_mb_master();
wait_gp_loops = 0;
}
/* Temporarily unlock the registry lock. */
* because it iterates on reader threads.
*/
/* Write new ptr before changing the qparity */
- smp_mb_master(RCU_MB_GROUP);
+ smp_mb_master();
/*
* Wait for readers to observe original parity or be quiescent.
* being freed. Must be done within rcu_registry_lock because it
* iterates on reader threads.
*/
- smp_mb_master(RCU_MB_GROUP);
+ smp_mb_master();
out:
mutex_unlock(&rcu_registry_lock);
mutex_unlock(&rcu_gp_lock);