X-Git-Url: http://git.liburcu.org/?p=urcu.git;a=blobdiff_plain;f=urcu-static.h;h=18e4826a5a31789c7cb408832421cbddb7d83c22;hp=eea39bb0641f8b5d295a46dd4f316761a6e85d21;hb=acfd099eae9026369f558e73b2a7e35860962d9d;hpb=42a3f1f99827c1bd73270966d4fffd6157809a7c diff --git a/urcu-static.h b/urcu-static.h index eea39bb..18e4826 100644 --- a/urcu-static.h +++ b/urcu-static.h @@ -181,23 +181,23 @@ extern int has_sys_membarrier; static inline void smp_mb_slave(int group) { if (likely(has_sys_membarrier)) - barrier(); + cmm_barrier(); else - smp_mb(); + cmm_smp_mb(); } #endif #ifdef RCU_MB static inline void smp_mb_slave(int group) { - smp_mb(); + cmm_smp_mb(); } #endif #ifdef RCU_SIGNAL static inline void smp_mb_slave(int group) { - barrier(); + cmm_barrier(); } #endif @@ -222,7 +222,7 @@ struct rcu_reader { unsigned long ctr; char need_mb; /* Data used for registry */ - struct list_head node __attribute__((aligned(CACHE_LINE_SIZE))); + struct cds_list_head node __attribute__((aligned(CAA_CACHE_LINE_SIZE))); pthread_t tid; }; @@ -250,7 +250,7 @@ static inline int rcu_gp_ongoing(unsigned long *ctr) * Make sure both tests below are done on the same version of *value * to insure consistency. */ - v = LOAD_SHARED(*ctr); + v = CMM_LOAD_SHARED(*ctr); return (v & RCU_GP_CTR_NEST_MASK) && ((v ^ rcu_gp_ctr) & RCU_GP_CTR_PHASE); } @@ -259,21 +259,21 @@ static inline void _rcu_read_lock(void) { unsigned long tmp; - barrier(); /* Ensure the compiler does not reorder us with mutex */ + cmm_barrier(); /* Ensure the compiler does not reorder us with mutex */ tmp = rcu_reader.ctr; /* * rcu_gp_ctr is * RCU_GP_COUNT | (~RCU_GP_CTR_PHASE or RCU_GP_CTR_PHASE) */ if (likely(!(tmp & RCU_GP_CTR_NEST_MASK))) { - _STORE_SHARED(rcu_reader.ctr, _LOAD_SHARED(rcu_gp_ctr)); + _CMM_STORE_SHARED(rcu_reader.ctr, _CMM_LOAD_SHARED(rcu_gp_ctr)); /* * Set active readers count for outermost nesting level before * accessing the pointer. See smp_mb_master(). */ smp_mb_slave(RCU_MB_GROUP); } else { - _STORE_SHARED(rcu_reader.ctr, tmp + RCU_GP_COUNT); + _CMM_STORE_SHARED(rcu_reader.ctr, tmp + RCU_GP_COUNT); } } @@ -288,14 +288,14 @@ static inline void _rcu_read_unlock(void) */ if (likely((tmp & RCU_GP_CTR_NEST_MASK) == RCU_GP_COUNT)) { smp_mb_slave(RCU_MB_GROUP); - _STORE_SHARED(rcu_reader.ctr, rcu_reader.ctr - RCU_GP_COUNT); + _CMM_STORE_SHARED(rcu_reader.ctr, rcu_reader.ctr - RCU_GP_COUNT); /* write rcu_reader.ctr before read futex */ smp_mb_slave(RCU_MB_GROUP); wake_up_gp(); } else { - _STORE_SHARED(rcu_reader.ctr, rcu_reader.ctr - RCU_GP_COUNT); + _CMM_STORE_SHARED(rcu_reader.ctr, rcu_reader.ctr - RCU_GP_COUNT); } - barrier(); /* Ensure the compiler does not reorder us with mutex */ + cmm_barrier(); /* Ensure the compiler does not reorder us with mutex */ } #ifdef __cplusplus