futextest.h 7.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262
  1. /* SPDX-License-Identifier: GPL-2.0-or-later */
  2. /******************************************************************************
  3. *
  4. * Copyright © International Business Machines Corp., 2009
  5. *
  6. * DESCRIPTION
  7. * Glibc independent futex library for testing kernel functionality.
  8. *
  9. * AUTHOR
  10. * Darren Hart <[email protected]>
  11. *
  12. * HISTORY
  13. * 2009-Nov-6: Initial version by Darren Hart <[email protected]>
  14. *
  15. *****************************************************************************/
  16. #ifndef _FUTEXTEST_H
  17. #define _FUTEXTEST_H
  18. #include <unistd.h>
  19. #include <sys/syscall.h>
  20. #include <sys/types.h>
  21. #include <linux/futex.h>
  22. typedef volatile u_int32_t futex_t;
  23. #define FUTEX_INITIALIZER 0
  24. /* Define the newer op codes if the system header file is not up to date. */
  25. #ifndef FUTEX_WAIT_BITSET
  26. #define FUTEX_WAIT_BITSET 9
  27. #endif
  28. #ifndef FUTEX_WAKE_BITSET
  29. #define FUTEX_WAKE_BITSET 10
  30. #endif
  31. #ifndef FUTEX_WAIT_REQUEUE_PI
  32. #define FUTEX_WAIT_REQUEUE_PI 11
  33. #endif
  34. #ifndef FUTEX_CMP_REQUEUE_PI
  35. #define FUTEX_CMP_REQUEUE_PI 12
  36. #endif
  37. #ifndef FUTEX_WAIT_REQUEUE_PI_PRIVATE
  38. #define FUTEX_WAIT_REQUEUE_PI_PRIVATE (FUTEX_WAIT_REQUEUE_PI | \
  39. FUTEX_PRIVATE_FLAG)
  40. #endif
  41. #ifndef FUTEX_REQUEUE_PI_PRIVATE
  42. #define FUTEX_CMP_REQUEUE_PI_PRIVATE (FUTEX_CMP_REQUEUE_PI | \
  43. FUTEX_PRIVATE_FLAG)
  44. #endif
  45. /**
  46. * futex() - SYS_futex syscall wrapper
  47. * @uaddr: address of first futex
  48. * @op: futex op code
  49. * @val: typically expected value of uaddr, but varies by op
  50. * @timeout: typically an absolute struct timespec (except where noted
  51. * otherwise). Overloaded by some ops
  52. * @uaddr2: address of second futex for some ops\
  53. * @val3: varies by op
  54. * @opflags: flags to be bitwise OR'd with op, such as FUTEX_PRIVATE_FLAG
  55. *
  56. * futex() is used by all the following futex op wrappers. It can also be
  57. * used for misuse and abuse testing. Generally, the specific op wrappers
  58. * should be used instead. It is a macro instead of an static inline function as
  59. * some of the types over overloaded (timeout is used for nr_requeue for
  60. * example).
  61. *
  62. * These argument descriptions are the defaults for all
  63. * like-named arguments in the following wrappers except where noted below.
  64. */
  65. #define futex(uaddr, op, val, timeout, uaddr2, val3, opflags) \
  66. syscall(SYS_futex, uaddr, op | opflags, val, timeout, uaddr2, val3)
  67. /**
  68. * futex_wait() - block on uaddr with optional timeout
  69. * @timeout: relative timeout
  70. */
  71. static inline int
  72. futex_wait(futex_t *uaddr, futex_t val, struct timespec *timeout, int opflags)
  73. {
  74. return futex(uaddr, FUTEX_WAIT, val, timeout, NULL, 0, opflags);
  75. }
  76. /**
  77. * futex_wake() - wake one or more tasks blocked on uaddr
  78. * @nr_wake: wake up to this many tasks
  79. */
  80. static inline int
  81. futex_wake(futex_t *uaddr, int nr_wake, int opflags)
  82. {
  83. return futex(uaddr, FUTEX_WAKE, nr_wake, NULL, NULL, 0, opflags);
  84. }
  85. /**
  86. * futex_wait_bitset() - block on uaddr with bitset
  87. * @bitset: bitset to be used with futex_wake_bitset
  88. */
  89. static inline int
  90. futex_wait_bitset(futex_t *uaddr, futex_t val, struct timespec *timeout,
  91. u_int32_t bitset, int opflags)
  92. {
  93. return futex(uaddr, FUTEX_WAIT_BITSET, val, timeout, NULL, bitset,
  94. opflags);
  95. }
  96. /**
  97. * futex_wake_bitset() - wake one or more tasks blocked on uaddr with bitset
  98. * @bitset: bitset to compare with that used in futex_wait_bitset
  99. */
  100. static inline int
  101. futex_wake_bitset(futex_t *uaddr, int nr_wake, u_int32_t bitset, int opflags)
  102. {
  103. return futex(uaddr, FUTEX_WAKE_BITSET, nr_wake, NULL, NULL, bitset,
  104. opflags);
  105. }
  106. /**
  107. * futex_lock_pi() - block on uaddr as a PI mutex
  108. * @detect: whether (1) or not (0) to perform deadlock detection
  109. */
  110. static inline int
  111. futex_lock_pi(futex_t *uaddr, struct timespec *timeout, int detect,
  112. int opflags)
  113. {
  114. return futex(uaddr, FUTEX_LOCK_PI, detect, timeout, NULL, 0, opflags);
  115. }
  116. /**
  117. * futex_unlock_pi() - release uaddr as a PI mutex, waking the top waiter
  118. */
  119. static inline int
  120. futex_unlock_pi(futex_t *uaddr, int opflags)
  121. {
  122. return futex(uaddr, FUTEX_UNLOCK_PI, 0, NULL, NULL, 0, opflags);
  123. }
  124. /**
  125. * futex_wake_op() - FIXME: COME UP WITH A GOOD ONE LINE DESCRIPTION
  126. */
  127. static inline int
  128. futex_wake_op(futex_t *uaddr, futex_t *uaddr2, int nr_wake, int nr_wake2,
  129. int wake_op, int opflags)
  130. {
  131. return futex(uaddr, FUTEX_WAKE_OP, nr_wake, nr_wake2, uaddr2, wake_op,
  132. opflags);
  133. }
  134. /**
  135. * futex_requeue() - requeue without expected value comparison, deprecated
  136. * @nr_wake: wake up to this many tasks
  137. * @nr_requeue: requeue up to this many tasks
  138. *
  139. * Due to its inherently racy implementation, futex_requeue() is deprecated in
  140. * favor of futex_cmp_requeue().
  141. */
  142. static inline int
  143. futex_requeue(futex_t *uaddr, futex_t *uaddr2, int nr_wake, int nr_requeue,
  144. int opflags)
  145. {
  146. return futex(uaddr, FUTEX_REQUEUE, nr_wake, nr_requeue, uaddr2, 0,
  147. opflags);
  148. }
  149. /**
  150. * futex_cmp_requeue() - requeue tasks from uaddr to uaddr2
  151. * @nr_wake: wake up to this many tasks
  152. * @nr_requeue: requeue up to this many tasks
  153. */
  154. static inline int
  155. futex_cmp_requeue(futex_t *uaddr, futex_t val, futex_t *uaddr2, int nr_wake,
  156. int nr_requeue, int opflags)
  157. {
  158. return futex(uaddr, FUTEX_CMP_REQUEUE, nr_wake, nr_requeue, uaddr2,
  159. val, opflags);
  160. }
  161. /**
  162. * futex_wait_requeue_pi() - block on uaddr and prepare to requeue to uaddr2
  163. * @uaddr: non-PI futex source
  164. * @uaddr2: PI futex target
  165. *
  166. * This is the first half of the requeue_pi mechanism. It shall always be
  167. * paired with futex_cmp_requeue_pi().
  168. */
  169. static inline int
  170. futex_wait_requeue_pi(futex_t *uaddr, futex_t val, futex_t *uaddr2,
  171. struct timespec *timeout, int opflags)
  172. {
  173. return futex(uaddr, FUTEX_WAIT_REQUEUE_PI, val, timeout, uaddr2, 0,
  174. opflags);
  175. }
  176. /**
  177. * futex_cmp_requeue_pi() - requeue tasks from uaddr to uaddr2 (PI aware)
  178. * @uaddr: non-PI futex source
  179. * @uaddr2: PI futex target
  180. * @nr_wake: wake up to this many tasks
  181. * @nr_requeue: requeue up to this many tasks
  182. */
  183. static inline int
  184. futex_cmp_requeue_pi(futex_t *uaddr, futex_t val, futex_t *uaddr2, int nr_wake,
  185. int nr_requeue, int opflags)
  186. {
  187. return futex(uaddr, FUTEX_CMP_REQUEUE_PI, nr_wake, nr_requeue, uaddr2,
  188. val, opflags);
  189. }
  190. /**
  191. * futex_cmpxchg() - atomic compare and exchange
  192. * @uaddr: The address of the futex to be modified
  193. * @oldval: The expected value of the futex
  194. * @newval: The new value to try and assign the futex
  195. *
  196. * Implement cmpxchg using gcc atomic builtins.
  197. * http://gcc.gnu.org/onlinedocs/gcc-4.1.0/gcc/Atomic-Builtins.html
  198. *
  199. * Return the old futex value.
  200. */
  201. static inline u_int32_t
  202. futex_cmpxchg(futex_t *uaddr, u_int32_t oldval, u_int32_t newval)
  203. {
  204. return __sync_val_compare_and_swap(uaddr, oldval, newval);
  205. }
  206. /**
  207. * futex_dec() - atomic decrement of the futex value
  208. * @uaddr: The address of the futex to be modified
  209. *
  210. * Return the new futex value.
  211. */
  212. static inline u_int32_t
  213. futex_dec(futex_t *uaddr)
  214. {
  215. return __sync_sub_and_fetch(uaddr, 1);
  216. }
  217. /**
  218. * futex_inc() - atomic increment of the futex value
  219. * @uaddr: the address of the futex to be modified
  220. *
  221. * Return the new futex value.
  222. */
  223. static inline u_int32_t
  224. futex_inc(futex_t *uaddr)
  225. {
  226. return __sync_add_and_fetch(uaddr, 1);
  227. }
  228. /**
  229. * futex_set() - atomic decrement of the futex value
  230. * @uaddr: the address of the futex to be modified
  231. * @newval: New value for the atomic_t
  232. *
  233. * Return the new futex value.
  234. */
  235. static inline u_int32_t
  236. futex_set(futex_t *uaddr, u_int32_t newval)
  237. {
  238. *uaddr = newval;
  239. return newval;
  240. }
  241. #endif