Annotation of embedaddon/nginx/src/os/unix/ngx_atomic.h, revision 1.1
1.1 ! misho 1:
! 2: /*
! 3: * Copyright (C) Igor Sysoev
! 4: * Copyright (C) Nginx, Inc.
! 5: */
! 6:
! 7:
! 8: #ifndef _NGX_ATOMIC_H_INCLUDED_
! 9: #define _NGX_ATOMIC_H_INCLUDED_
! 10:
! 11:
! 12: #include <ngx_config.h>
! 13: #include <ngx_core.h>
! 14:
! 15:
! 16: #if (NGX_HAVE_LIBATOMIC)
! 17:
! 18: #define AO_REQUIRE_CAS
! 19: #include <atomic_ops.h>
! 20:
! 21: #define NGX_HAVE_ATOMIC_OPS 1
! 22:
! 23: typedef long ngx_atomic_int_t;
! 24: typedef AO_t ngx_atomic_uint_t;
! 25: typedef volatile ngx_atomic_uint_t ngx_atomic_t;
! 26:
! 27: #if (NGX_PTR_SIZE == 8)
! 28: #define NGX_ATOMIC_T_LEN (sizeof("-9223372036854775808") - 1)
! 29: #else
! 30: #define NGX_ATOMIC_T_LEN (sizeof("-2147483648") - 1)
! 31: #endif
! 32:
! 33: #define ngx_atomic_cmp_set(lock, old, new) \
! 34: AO_compare_and_swap(lock, old, new)
! 35: #define ngx_atomic_fetch_add(value, add) \
! 36: AO_fetch_and_add(value, add)
! 37: #define ngx_memory_barrier() AO_nop()
! 38: #define ngx_cpu_pause()
! 39:
! 40:
! 41: #elif (NGX_DARWIN_ATOMIC)
! 42:
! 43: /*
! 44: * use Darwin 8 atomic(3) and barrier(3) operations
! 45: * optimized at run-time for UP and SMP
! 46: */
! 47:
! 48: #include <libkern/OSAtomic.h>
! 49:
! 50: /* "bool" conflicts with perl's CORE/handy.h */
! 51: #if 0
! 52: #undef bool
! 53: #endif
! 54:
! 55:
! 56: #define NGX_HAVE_ATOMIC_OPS 1
! 57:
! 58: #if (NGX_PTR_SIZE == 8)
! 59:
! 60: typedef int64_t ngx_atomic_int_t;
! 61: typedef uint64_t ngx_atomic_uint_t;
! 62: #define NGX_ATOMIC_T_LEN (sizeof("-9223372036854775808") - 1)
! 63:
! 64: #define ngx_atomic_cmp_set(lock, old, new) \
! 65: OSAtomicCompareAndSwap64Barrier(old, new, (int64_t *) lock)
! 66:
! 67: #define ngx_atomic_fetch_add(value, add) \
! 68: (OSAtomicAdd64(add, (int64_t *) value) - add)
! 69:
! 70: #else
! 71:
! 72: typedef int32_t ngx_atomic_int_t;
! 73: typedef uint32_t ngx_atomic_uint_t;
! 74: #define NGX_ATOMIC_T_LEN (sizeof("-2147483648") - 1)
! 75:
! 76: #define ngx_atomic_cmp_set(lock, old, new) \
! 77: OSAtomicCompareAndSwap32Barrier(old, new, (int32_t *) lock)
! 78:
! 79: #define ngx_atomic_fetch_add(value, add) \
! 80: (OSAtomicAdd32(add, (int32_t *) value) - add)
! 81:
! 82: #endif
! 83:
! 84: #define ngx_memory_barrier() OSMemoryBarrier()
! 85:
! 86: #define ngx_cpu_pause()
! 87:
! 88: typedef volatile ngx_atomic_uint_t ngx_atomic_t;
! 89:
! 90:
! 91: #elif (NGX_HAVE_GCC_ATOMIC)
! 92:
! 93: /* GCC 4.1 builtin atomic operations */
! 94:
! 95: #define NGX_HAVE_ATOMIC_OPS 1
! 96:
! 97: typedef long ngx_atomic_int_t;
! 98: typedef unsigned long ngx_atomic_uint_t;
! 99:
! 100: #if (NGX_PTR_SIZE == 8)
! 101: #define NGX_ATOMIC_T_LEN (sizeof("-9223372036854775808") - 1)
! 102: #else
! 103: #define NGX_ATOMIC_T_LEN (sizeof("-2147483648") - 1)
! 104: #endif
! 105:
! 106: typedef volatile ngx_atomic_uint_t ngx_atomic_t;
! 107:
! 108:
! 109: #define ngx_atomic_cmp_set(lock, old, set) \
! 110: __sync_bool_compare_and_swap(lock, old, set)
! 111:
! 112: #define ngx_atomic_fetch_add(value, add) \
! 113: __sync_fetch_and_add(value, add)
! 114:
! 115: #define ngx_memory_barrier() __sync_synchronize()
! 116:
! 117: #if ( __i386__ || __i386 || __amd64__ || __amd64 )
! 118: #define ngx_cpu_pause() __asm__ ("pause")
! 119: #else
! 120: #define ngx_cpu_pause()
! 121: #endif
! 122:
! 123:
! 124: #elif ( __i386__ || __i386 )
! 125:
! 126: typedef int32_t ngx_atomic_int_t;
! 127: typedef uint32_t ngx_atomic_uint_t;
! 128: typedef volatile ngx_atomic_uint_t ngx_atomic_t;
! 129: #define NGX_ATOMIC_T_LEN (sizeof("-2147483648") - 1)
! 130:
! 131:
! 132: #if ( __SUNPRO_C )
! 133:
! 134: #define NGX_HAVE_ATOMIC_OPS 1
! 135:
! 136: ngx_atomic_uint_t
! 137: ngx_atomic_cmp_set(ngx_atomic_t *lock, ngx_atomic_uint_t old,
! 138: ngx_atomic_uint_t set);
! 139:
! 140: ngx_atomic_int_t
! 141: ngx_atomic_fetch_add(ngx_atomic_t *value, ngx_atomic_int_t add);
! 142:
! 143: /*
! 144: * Sun Studio 12 exits with segmentation fault on '__asm ("pause")',
! 145: * so ngx_cpu_pause is declared in src/os/unix/ngx_sunpro_x86.il
! 146: */
! 147:
! 148: void
! 149: ngx_cpu_pause(void);
! 150:
! 151: /* the code in src/os/unix/ngx_sunpro_x86.il */
! 152:
! 153: #define ngx_memory_barrier() __asm (".volatile"); __asm (".nonvolatile")
! 154:
! 155:
! 156: #else /* ( __GNUC__ || __INTEL_COMPILER ) */
! 157:
! 158: #define NGX_HAVE_ATOMIC_OPS 1
! 159:
! 160: #include "ngx_gcc_atomic_x86.h"
! 161:
! 162: #endif
! 163:
! 164:
! 165: #elif ( __amd64__ || __amd64 )
! 166:
! 167: typedef int64_t ngx_atomic_int_t;
! 168: typedef uint64_t ngx_atomic_uint_t;
! 169: typedef volatile ngx_atomic_uint_t ngx_atomic_t;
! 170: #define NGX_ATOMIC_T_LEN (sizeof("-9223372036854775808") - 1)
! 171:
! 172:
! 173: #if ( __SUNPRO_C )
! 174:
! 175: #define NGX_HAVE_ATOMIC_OPS 1
! 176:
! 177: ngx_atomic_uint_t
! 178: ngx_atomic_cmp_set(ngx_atomic_t *lock, ngx_atomic_uint_t old,
! 179: ngx_atomic_uint_t set);
! 180:
! 181: ngx_atomic_int_t
! 182: ngx_atomic_fetch_add(ngx_atomic_t *value, ngx_atomic_int_t add);
! 183:
! 184: /*
! 185: * Sun Studio 12 exits with segmentation fault on '__asm ("pause")',
! 186: * so ngx_cpu_pause is declared in src/os/unix/ngx_sunpro_amd64.il
! 187: */
! 188:
! 189: void
! 190: ngx_cpu_pause(void);
! 191:
! 192: /* the code in src/os/unix/ngx_sunpro_amd64.il */
! 193:
! 194: #define ngx_memory_barrier() __asm (".volatile"); __asm (".nonvolatile")
! 195:
! 196:
! 197: #else /* ( __GNUC__ || __INTEL_COMPILER ) */
! 198:
! 199: #define NGX_HAVE_ATOMIC_OPS 1
! 200:
! 201: #include "ngx_gcc_atomic_amd64.h"
! 202:
! 203: #endif
! 204:
! 205:
! 206: #elif ( __sparc__ || __sparc || __sparcv9 )
! 207:
! 208: #if (NGX_PTR_SIZE == 8)
! 209:
! 210: typedef int64_t ngx_atomic_int_t;
! 211: typedef uint64_t ngx_atomic_uint_t;
! 212: #define NGX_ATOMIC_T_LEN (sizeof("-9223372036854775808") - 1)
! 213:
! 214: #else
! 215:
! 216: typedef int32_t ngx_atomic_int_t;
! 217: typedef uint32_t ngx_atomic_uint_t;
! 218: #define NGX_ATOMIC_T_LEN (sizeof("-2147483648") - 1)
! 219:
! 220: #endif
! 221:
! 222: typedef volatile ngx_atomic_uint_t ngx_atomic_t;
! 223:
! 224:
! 225: #if ( __SUNPRO_C )
! 226:
! 227: #define NGX_HAVE_ATOMIC_OPS 1
! 228:
! 229: #include "ngx_sunpro_atomic_sparc64.h"
! 230:
! 231:
! 232: #else /* ( __GNUC__ || __INTEL_COMPILER ) */
! 233:
! 234: #define NGX_HAVE_ATOMIC_OPS 1
! 235:
! 236: #include "ngx_gcc_atomic_sparc64.h"
! 237:
! 238: #endif
! 239:
! 240:
! 241: #elif ( __powerpc__ || __POWERPC__ )
! 242:
! 243: #define NGX_HAVE_ATOMIC_OPS 1
! 244:
! 245: #if (NGX_PTR_SIZE == 8)
! 246:
! 247: typedef int64_t ngx_atomic_int_t;
! 248: typedef uint64_t ngx_atomic_uint_t;
! 249: #define NGX_ATOMIC_T_LEN (sizeof("-9223372036854775808") - 1)
! 250:
! 251: #else
! 252:
! 253: typedef int32_t ngx_atomic_int_t;
! 254: typedef uint32_t ngx_atomic_uint_t;
! 255: #define NGX_ATOMIC_T_LEN (sizeof("-2147483648") - 1)
! 256:
! 257: #endif
! 258:
! 259: typedef volatile ngx_atomic_uint_t ngx_atomic_t;
! 260:
! 261:
! 262: #include "ngx_gcc_atomic_ppc.h"
! 263:
! 264: #endif
! 265:
! 266:
! 267: #if !(NGX_HAVE_ATOMIC_OPS)
! 268:
! 269: #define NGX_HAVE_ATOMIC_OPS 0
! 270:
! 271: typedef int32_t ngx_atomic_int_t;
! 272: typedef uint32_t ngx_atomic_uint_t;
! 273: typedef volatile ngx_atomic_uint_t ngx_atomic_t;
! 274: #define NGX_ATOMIC_T_LEN (sizeof("-2147483648") - 1)
! 275:
! 276:
! 277: static ngx_inline ngx_atomic_uint_t
! 278: ngx_atomic_cmp_set(ngx_atomic_t *lock, ngx_atomic_uint_t old,
! 279: ngx_atomic_uint_t set)
! 280: {
! 281: if (*lock == old) {
! 282: *lock = set;
! 283: return 1;
! 284: }
! 285:
! 286: return 0;
! 287: }
! 288:
! 289:
! 290: static ngx_inline ngx_atomic_int_t
! 291: ngx_atomic_fetch_add(ngx_atomic_t *value, ngx_atomic_int_t add)
! 292: {
! 293: ngx_atomic_int_t old;
! 294:
! 295: old = *value;
! 296: *value += add;
! 297:
! 298: return old;
! 299: }
! 300:
! 301: #define ngx_memory_barrier()
! 302: #define ngx_cpu_pause()
! 303:
! 304: #endif
! 305:
! 306:
! 307: void ngx_spinlock(ngx_atomic_t *lock, ngx_atomic_int_t value, ngx_uint_t spin);
! 308:
! 309: #define ngx_trylock(lock) (*(lock) == 0 && ngx_atomic_cmp_set(lock, 0, 1))
! 310: #define ngx_unlock(lock) *(lock) = 0
! 311:
! 312:
! 313: #endif /* _NGX_ATOMIC_H_INCLUDED_ */
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to ngx_atomic.h CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / nginx / src / os / unix