commit d9cf9ffe8b1df575a3d9c9a8fd08e5b7463a1c38
Author: Torvald Riegel <triegel@redhat.com>
Date: Thu Dec 4 14:29:27 2014 +0100
pthread_once: Use futex wrappers with error checking.
@@ -17,7 +17,7 @@
<http://www.gnu.org/licenses/>. */
#include "pthreadP.h"
-#include <lowlevellock.h>
+#include <futex-internal.h>
#include <atomic.h>
@@ -35,7 +35,7 @@ clear_once_control (void *arg)
get interrupted (see __pthread_once), so all we need to relay to other
threads is the state being reset again. */
atomic_store_relaxed (once_control, 0);
- lll_futex_wake (once_control, INT_MAX, LLL_PRIVATE);
+ futex_wake (once_control, INT_MAX, FUTEX_PRIVATE);
}
@@ -100,8 +100,11 @@ __pthread_once_slow (pthread_once_t *once_control, void (*init_routine) (void))
is set and __PTHREAD_ONCE_DONE is not. */
if (val == newval)
{
- /* Same generation, some other thread was faster. Wait. */
- lll_futex_wait (once_control, newval, LLL_PRIVATE);
+ /* Same generation, some other thread was faster. Wait and
+ retry. Ignore the return value because all possible
+ values (0, -EWOULDBLOCK, -EINTR) need to be handled the
+ same. */
+ futex_wait (once_control, newval, FUTEX_PRIVATE);
continue;
}
}
@@ -122,7 +125,7 @@ __pthread_once_slow (pthread_once_t *once_control, void (*init_routine) (void))
atomic_store_release (once_control, __PTHREAD_ONCE_DONE);
/* Wake up all other threads. */
- lll_futex_wake (once_control, INT_MAX, LLL_PRIVATE);
+ futex_wake (once_control, INT_MAX, FUTEX_PRIVATE);
break;
}