80bdb01fb6f9e834c2d27564562edc34ce51e8e4
2 * Copyright (C) 2011 EfficiOS Inc.
3 * Copyright (C) 2011 Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
5 * SPDX-License-Identifier: GPL-2.0-only
13 #include <urcu/futex.h>
15 #include <common/common.h>
20 * This futex wait/wake scheme only works for N wakers / 1 waiters. Hence the
21 * "nto1" added to all function signature.
23 * Please see wait_gp()/update_counter_and_wait() calls in urcu.c in the urcu
24 * git tree for a detail example of this scheme being used. futex_async() is
25 * the urcu wrapper over the futex() sycall.
27 * There is also a formal verification available in the git tree.
29 * branch: formal-model
30 * commit id: 2a8044f3493046fcc8c67016902dc7beec6f026a
32 * Ref: git://git.lttng.org/userspace-rcu.git
36 * Update futex according to active or not. This scheme is used to wake every
37 * libust waiting on the shared memory map futex hence the INT_MAX used in the
38 * futex() call. If active, we set the value and wake everyone else we indicate
39 * that we are gone (cleanup() case).
42 void futex_wait_update(int32_t *futex
, int active
)
45 uatomic_set(futex
, 1);
46 if (futex_async(futex
, FUTEX_WAKE
,
47 INT_MAX
, NULL
, NULL
, 0) < 0) {
48 PERROR("futex_async");
52 uatomic_set(futex
, 0);
55 DBG("Futex wait update active %d", active
);
62 void futex_nto1_prepare(int32_t *futex
)
64 uatomic_set(futex
, -1);
67 DBG("Futex n to 1 prepare done");
74 void futex_nto1_wait(int32_t *futex
)
78 while (uatomic_read(futex
) == -1) {
79 if (!futex_async(futex
, FUTEX_WAIT
, -1, NULL
, NULL
, 0)) {
81 * Prior queued wakeups queued by unrelated code
82 * using the same address can cause futex wait to
83 * return 0 even through the futex value is still
84 * -1 (spurious wakeups). Check the value again
85 * in user-space to validate whether it really
92 /* Value already changed. */
95 /* Retry if interrupted by signal. */
96 break; /* Get out of switch. Check again. */
98 /* Unexpected error. */
99 PERROR("futex_async");
104 DBG("Futex n to 1 wait done");
111 void futex_nto1_wake(int32_t *futex
)
113 if (caa_unlikely(uatomic_read(futex
) != -1))
115 uatomic_set(futex
, 0);
116 if (futex_async(futex
, FUTEX_WAKE
, 1, NULL
, NULL
, 0) < 0) {
117 PERROR("futex_async");
121 DBG("Futex n to 1 wake done");
This page took 0.030772 seconds and 3 git commands to generate.