Add util_atomic_decrement and util_atomic_bool_compare_exchange

Add util_atomic_decrement and util_atomic_bool_compare_exchange
to utils_concurrency.h.

Signed-off-by: Lukasz Dorau <[email protected]>

Author: ldorau

src/utils/utils_concurrency.h

@@ -38,7 +38,7 @@ void util_mutex_destroy(os_mutex_t *mutex);
 int util_mutex_lock(os_mutex_t *mutex);
 int util_mutex_unlock(os_mutex_t *mutex);
 
-#if defined(_WIN32)
+#if defined(_WIN32) /* Windows part starts here */
 static __inline unsigned char util_lssb_index(long long value) {
     unsigned long ret;
     _BitScanForward64(&ret, value);
@@ -60,7 +60,14 @@ static __inline unsigned char util_mssb_index(long long value) {
     InterlockedExchange64((LONG64 volatile *)object, (LONG64)desired)
 #define util_atomic_increment(object)                                          \
     InterlockedIncrement64((LONG64 volatile *)object)
-#else
+#define util_atomic_decrement(object)                                          \
+    InterlockedDecrement64((LONG64 volatile *)object)
+#define util_atomic_bool_compare_exchange(object, oldval, newval)              \
+    (InterlockedCompareExchange64((LONG64 volatile *)object, (LONG64)newval,   \
+                                  (LONG64)oldval) == (LONG64)oldval)
+
+#else /* NON-Windows part starts here */
+
 #define util_lssb_index(x) ((unsigned char)__builtin_ctzll(x))
 #define util_mssb_index(x) ((unsigned char)(63 - __builtin_clzll(x)))
 #define util_atomic_load_acquire(object, dest)                                 \
@@ -69,6 +76,10 @@ static __inline unsigned char util_mssb_index(long long value) {
     __atomic_store_n(object, desired, memory_order_release)
 #define util_atomic_increment(object)                                          \
     __atomic_add_fetch(object, 1, __ATOMIC_ACQ_REL)
+#define util_atomic_decrement(object)                                          \
+    __atomic_sub_fetch(object, 1, __ATOMIC_ACQ_REL)
+#define util_atomic_bool_compare_exchange(object, oldval, newval)              \
+    __sync_bool_compare_and_swap(object, oldval, newval)
 #endif
 
 #ifdef __cplusplus