gamzinav/haproxy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

MINOR: threads: add test and set/reset operations

Browse Source 
This just adds a set of naive bts/btr operations based on OR/AND. Later
it could rely on pl_bts/btr to use arch-specific versions if needed.
This commit is contained in:
Willy Tarreau 2018-01-25 17:43:58 +01:00
parent f61f0cb95f
commit 5266b3e12d
1 changed files with 43 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
include/common/hathreads.h
View File

@ -45,6 +45,24 @@ extern THREAD_LOCAL unsigned long tid_bit; /* The bit corresponding to the threa
*(val) = new; \
__old; \
})
#define HA_ATOMIC_BTS(val, bit) \
({ \
typeof((val)) __p = (val); \
typeof(*__p) __b = (1UL << (bit)); \
typeof(*__p) __t = *__p & __b; \
if (!__t) \
*__p |= __b; \
__t; \
})
#define HA_ATOMIC_BTR(val, bit) \
({ \
typeof((val)) __p = (val); \
typeof(*__p) __b = (1UL << (bit)); \
typeof(*__p) __t = *__p & __b; \
if (__t) \
*__p &= ~__b; \
__t; \
})
#define HA_ATOMIC_STORE(val, new) ({*(val) = new;})
#define HA_ATOMIC_UPDATE_MAX(val, new) \
({ \
@ -157,6 +175,19 @@ static inline void __ha_barrier_full(void)
} while (!__sync_bool_compare_and_swap(__val, __old, __new)); \
__old; \
})
#define HA_ATOMIC_BTS(val, bit) \
({ \
typeof(*(val)) __b = (1UL << (bit)); \
__sync_fetch_and_or((val), __b) & __b; \
})
#define HA_ATOMIC_BTR(val, bit) \
({ \
typeof(*(val)) __b = (1UL << (bit)); \
__sync_fetch_and_and((val), ~__b) & __b; \
})
#define HA_ATOMIC_STORE(val, new) \
({ \
typeof((val)) __val = (val); \
@ -172,6 +203,18 @@ static inline void __ha_barrier_full(void)
#define HA_ATOMIC_SUB(val, i) __atomic_sub_fetch(val, i, 0)
#define HA_ATOMIC_AND(val, flags) __atomic_and_fetch(val, flags, 0)
#define HA_ATOMIC_OR(val, flags) __atomic_or_fetch(val, flags, 0)
#define HA_ATOMIC_BTS(val, bit) \
({ \
typeof(*(val)) __b = (1UL << (bit)); \
__sync_fetch_and_or((val), __b) & __b; \
})
#define HA_ATOMIC_BTR(val, bit) \
({ \
typeof(*(val)) __b = (1UL << (bit)); \
__sync_fetch_and_and((val), ~__b) & __b; \
})
#define HA_ATOMIC_XCHG(val, new) __atomic_exchange_n(val, new, 0)
#define HA_ATOMIC_STORE(val, new) __atomic_store_n(val, new, 0)
#endif