diff options
Diffstat (limited to 'core/safe_refcount.cpp')
| -rw-r--r-- | core/safe_refcount.cpp | 56 |
1 files changed, 25 insertions, 31 deletions
diff --git a/core/safe_refcount.cpp b/core/safe_refcount.cpp index 50617f2062..cbd79a322f 100644 --- a/core/safe_refcount.cpp +++ b/core/safe_refcount.cpp @@ -28,15 +28,13 @@ /*************************************************************************/ #include "safe_refcount.h" - // Atomic functions, these are used for multithread safe reference counters! #ifdef NO_THREADS +uint32_t atomic_conditional_increment(register uint32_t *pw) { -uint32_t atomic_conditional_increment( register uint32_t * pw ) { - - if (*pw==0) + if (*pw == 0) return 0; (*pw)++; @@ -44,20 +42,18 @@ uint32_t atomic_conditional_increment( register uint32_t * pw ) { return *pw; } -uint32_t atomic_increment( register uint32_t * pw ) { +uint32_t atomic_increment(register uint32_t *pw) { (*pw)++; return *pw; - } -uint32_t atomic_decrement( register uint32_t * pw ) { +uint32_t atomic_decrement(register uint32_t *pw) { (*pw)--; return *pw; - } #else @@ -66,54 +62,52 @@ uint32_t atomic_decrement( register uint32_t * pw ) { // don't pollute my namespace! #include <windows.h> -uint32_t atomic_conditional_increment( register uint32_t * pw ) { +uint32_t atomic_conditional_increment(register uint32_t *pw) { /* try to increment until it actually works */ // taken from boost while (true) { - uint32_t tmp = static_cast< uint32_t const volatile& >( *pw ); - if( tmp == 0 ) - return 0; // if zero, can't add to it anymore - if( InterlockedCompareExchange( (LONG volatile*)pw, tmp + 1, tmp ) == tmp ) - return tmp+1; + uint32_t tmp = static_cast<uint32_t const volatile &>(*pw); + if (tmp == 0) + return 0; // if zero, can't add to it anymore + if (InterlockedCompareExchange((LONG volatile *)pw, tmp + 1, tmp) == tmp) + return tmp + 1; } } -uint32_t atomic_decrement( register uint32_t * pw ) { - return InterlockedDecrement( (LONG volatile*)pw ); +uint32_t atomic_decrement(register uint32_t *pw) { + return InterlockedDecrement((LONG volatile *)pw); } -uint32_t atomic_increment( register uint32_t * pw ) { - return InterlockedIncrement( (LONG volatile*)pw ); +uint32_t atomic_increment(register uint32_t *pw) { + return InterlockedIncrement((LONG volatile *)pw); } #elif defined(__GNUC__) -uint32_t atomic_conditional_increment( register uint32_t * pw ) { +uint32_t atomic_conditional_increment(register uint32_t *pw) { while (true) { - uint32_t tmp = static_cast< uint32_t const volatile& >( *pw ); - if( tmp == 0 ) - return 0; // if zero, can't add to it anymore - if( __sync_val_compare_and_swap( pw, tmp, tmp + 1 ) == tmp ) - return tmp+1; + uint32_t tmp = static_cast<uint32_t const volatile &>(*pw); + if (tmp == 0) + return 0; // if zero, can't add to it anymore + if (__sync_val_compare_and_swap(pw, tmp, tmp + 1) == tmp) + return tmp + 1; } } -uint32_t atomic_decrement( register uint32_t * pw ) { - - return __sync_sub_and_fetch(pw,1); +uint32_t atomic_decrement(register uint32_t *pw) { + return __sync_sub_and_fetch(pw, 1); } -uint32_t atomic_increment( register uint32_t * pw ) { - - return __sync_add_and_fetch(pw,1); +uint32_t atomic_increment(register uint32_t *pw) { + return __sync_add_and_fetch(pw, 1); } #else - //no threads supported? +//no threads supported? #error Must provide atomic functions for this platform or compiler! #endif |