atomic.h 5.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318
  1. #ifndef _ATOMIC_H
  2. #define _ATOMIC_H
  3. #include <stdint.h>
  4. #include "atomic_arch.h"
  5. #ifdef a_ll
  6. #ifndef a_pre_llsc
  7. #define a_pre_llsc()
  8. #endif
  9. #ifndef a_post_llsc
  10. #define a_post_llsc()
  11. #endif
  12. #ifndef a_cas
  13. #define a_cas a_cas
  14. static inline int a_cas(volatile int *p, int t, int s)
  15. {
  16. int old;
  17. a_pre_llsc();
  18. do old = a_ll(p);
  19. while (old==t && !a_sc(p, s));
  20. a_post_llsc();
  21. return old;
  22. }
  23. #endif
  24. #ifndef a_swap
  25. #define a_swap a_swap
  26. static inline int a_swap(volatile int *p, int v)
  27. {
  28. int old;
  29. a_pre_llsc();
  30. do old = a_ll(p);
  31. while (!a_sc(p, v));
  32. a_post_llsc();
  33. return old;
  34. }
  35. #endif
  36. #ifndef a_fetch_add
  37. #define a_fetch_add a_fetch_add
  38. static inline int a_fetch_add(volatile int *p, int v)
  39. {
  40. int old;
  41. a_pre_llsc();
  42. do old = a_ll(p);
  43. while (!a_sc(p, (unsigned)old + v));
  44. a_post_llsc();
  45. return old;
  46. }
  47. #endif
  48. #ifndef a_fetch_and
  49. #define a_fetch_and a_fetch_and
  50. static inline int a_fetch_and(volatile int *p, int v)
  51. {
  52. int old;
  53. a_pre_llsc();
  54. do old = a_ll(p);
  55. while (!a_sc(p, old & v));
  56. a_post_llsc();
  57. return old;
  58. }
  59. #endif
  60. #ifndef a_fetch_or
  61. #define a_fetch_or a_fetch_or
  62. static inline int a_fetch_or(volatile int *p, int v)
  63. {
  64. int old;
  65. a_pre_llsc();
  66. do old = a_ll(p);
  67. while (!a_sc(p, old | v));
  68. a_post_llsc();
  69. return old;
  70. }
  71. #endif
  72. #endif
  73. #ifdef a_ll_p
  74. #ifndef a_cas_p
  75. #define a_cas_p a_cas_p
  76. static inline void *a_cas_p(volatile void *p, void *t, void *s)
  77. {
  78. void *old;
  79. a_pre_llsc();
  80. do old = a_ll_p(p);
  81. while (old==t && !a_sc_p(p, s));
  82. a_post_llsc();
  83. return old;
  84. }
  85. #endif
  86. #endif
  87. #ifndef a_cas
  88. #error missing definition of a_cas
  89. #endif
  90. #ifndef a_swap
  91. #define a_swap a_swap
  92. static inline int a_swap(volatile int *p, int v)
  93. {
  94. int old;
  95. do old = *p;
  96. while (a_cas(p, old, v) != old);
  97. return old;
  98. }
  99. #endif
  100. #ifndef a_fetch_add
  101. #define a_fetch_add a_fetch_add
  102. static inline int a_fetch_add(volatile int *p, int v)
  103. {
  104. int old;
  105. do old = *p;
  106. while (a_cas(p, old, (unsigned)old+v) != old);
  107. return old;
  108. }
  109. #endif
  110. #ifndef a_fetch_and
  111. #define a_fetch_and a_fetch_and
  112. static inline int a_fetch_and(volatile int *p, int v)
  113. {
  114. int old;
  115. do old = *p;
  116. while (a_cas(p, old, old&v) != old);
  117. return old;
  118. }
  119. #endif
  120. #ifndef a_fetch_or
  121. #define a_fetch_or a_fetch_or
  122. static inline int a_fetch_or(volatile int *p, int v)
  123. {
  124. int old;
  125. do old = *p;
  126. while (a_cas(p, old, old|v) != old);
  127. return old;
  128. }
  129. #endif
  130. #ifndef a_and
  131. #define a_and a_and
  132. static inline void a_and(volatile int *p, int v)
  133. {
  134. a_fetch_and(p, v);
  135. }
  136. #endif
  137. #ifndef a_or
  138. #define a_or a_or
  139. static inline void a_or(volatile int *p, int v)
  140. {
  141. a_fetch_or(p, v);
  142. }
  143. #endif
  144. #ifndef a_inc
  145. #define a_inc a_inc
  146. static inline void a_inc(volatile int *p)
  147. {
  148. a_fetch_add(p, 1);
  149. }
  150. #endif
  151. #ifndef a_dec
  152. #define a_dec a_dec
  153. static inline void a_dec(volatile int *p)
  154. {
  155. a_fetch_add(p, -1);
  156. }
  157. #endif
  158. #ifndef a_store
  159. #define a_store a_store
  160. static inline void a_store(volatile int *p, int v)
  161. {
  162. #ifdef a_barrier
  163. a_barrier();
  164. *p = v;
  165. a_barrier();
  166. #else
  167. a_swap(p, v);
  168. #endif
  169. }
  170. #endif
  171. #ifndef a_barrier
  172. #define a_barrier a_barrier
  173. static void a_barrier()
  174. {
  175. volatile int tmp = 0;
  176. a_cas(&tmp, 0, 0);
  177. }
  178. #endif
  179. #ifndef a_spin
  180. #define a_spin a_barrier
  181. #endif
  182. #ifndef a_and_64
  183. #define a_and_64 a_and_64
  184. static inline void a_and_64(volatile uint64_t *p, uint64_t v)
  185. {
  186. union { uint64_t v; uint32_t r[2]; } u = { v };
  187. if (u.r[0]+1) a_and((int *)p, u.r[0]);
  188. if (u.r[1]+1) a_and((int *)p+1, u.r[1]);
  189. }
  190. #endif
  191. #ifndef a_or_64
  192. #define a_or_64 a_or_64
  193. static inline void a_or_64(volatile uint64_t *p, uint64_t v)
  194. {
  195. union { uint64_t v; uint32_t r[2]; } u = { v };
  196. if (u.r[0]) a_or((int *)p, u.r[0]);
  197. if (u.r[1]) a_or((int *)p+1, u.r[1]);
  198. }
  199. #endif
  200. #ifndef a_cas_p
  201. typedef char a_cas_p_undefined_but_pointer_not_32bit[-sizeof(char) == 0xffffffff ? 1 : -1];
  202. #define a_cas_p a_cas_p
  203. static inline void *a_cas_p(volatile void *p, void *t, void *s)
  204. {
  205. return (void *)a_cas((volatile int *)p, (int)t, (int)s);
  206. }
  207. #endif
  208. #ifndef a_or_l
  209. #define a_or_l a_or_l
  210. static inline void a_or_l(volatile void *p, long v)
  211. {
  212. if (sizeof(long) == sizeof(int)) a_or(p, v);
  213. else a_or_64(p, v);
  214. }
  215. #endif
  216. #ifndef a_crash
  217. #define a_crash a_crash
  218. static inline void a_crash()
  219. {
  220. *(volatile char *)0=0;
  221. }
  222. #endif
  223. #ifndef a_ctz_32
  224. #define a_ctz_32 a_ctz_32
  225. static inline int a_ctz_32(uint32_t x)
  226. {
  227. #ifdef a_clz_32
  228. return 31-a_clz_32(x&-x);
  229. #else
  230. static const char debruijn32[32] = {
  231. 0, 1, 23, 2, 29, 24, 19, 3, 30, 27, 25, 11, 20, 8, 4, 13,
  232. 31, 22, 28, 18, 26, 10, 7, 12, 21, 17, 9, 6, 16, 5, 15, 14
  233. };
  234. return debruijn32[(x&-x)*0x076be629 >> 27];
  235. #endif
  236. }
  237. #endif
  238. #ifndef a_ctz_64
  239. #define a_ctz_64 a_ctz_64
  240. static inline int a_ctz_64(uint64_t x)
  241. {
  242. static const char debruijn64[64] = {
  243. 0, 1, 2, 53, 3, 7, 54, 27, 4, 38, 41, 8, 34, 55, 48, 28,
  244. 62, 5, 39, 46, 44, 42, 22, 9, 24, 35, 59, 56, 49, 18, 29, 11,
  245. 63, 52, 6, 26, 37, 40, 33, 47, 61, 45, 43, 21, 23, 58, 17, 10,
  246. 51, 25, 36, 32, 60, 20, 57, 16, 50, 31, 19, 15, 30, 14, 13, 12
  247. };
  248. if (sizeof(long) < 8) {
  249. uint32_t y = x;
  250. if (!y) {
  251. y = x>>32;
  252. return 32 + a_ctz_32(y);
  253. }
  254. return a_ctz_32(y);
  255. }
  256. return debruijn64[(x&-x)*0x022fdd63cc95386dull >> 58];
  257. }
  258. #endif
  259. static inline int a_ctz_l(unsigned long x)
  260. {
  261. return (sizeof(long) < 8) ? a_ctz_32(x) : a_ctz_64(x);
  262. }
  263. #ifndef a_clz_64
  264. #define a_clz_64 a_clz_64
  265. static inline int a_clz_64(uint64_t x)
  266. {
  267. #ifdef a_clz_32
  268. if (x>>32)
  269. return a_clz_32(x>>32);
  270. return a_clz_32(x) + 32;
  271. #else
  272. uint32_t y;
  273. int r;
  274. if (x>>32) y=x>>32, r=0; else y=x, r=32;
  275. if (y>>16) y>>=16; else r |= 16;
  276. if (y>>8) y>>=8; else r |= 8;
  277. if (y>>4) y>>=4; else r |= 4;
  278. if (y>>2) y>>=2; else r |= 2;
  279. return r | !(y>>1);
  280. #endif
  281. }
  282. #endif
  283. #endif