1 /* Set current priority ceiling of pthread_mutex_t.
2 Copyright (C) 2006-2013 Free Software Foundation, Inc.
3 This file is part of the GNU C Library.
4 Contributed by Jakub Jelinek <jakub@redhat.com>, 2006.
6 The GNU C Library is free software; you can redistribute it and/or
7 modify it under the terms of the GNU Lesser General Public
8 License as published by the Free Software Foundation; either
9 version 2.1 of the License, or (at your option) any later version.
11 The GNU C Library is distributed in the hope that it will be useful,
12 but WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 Lesser General Public License for more details.
16 You should have received a copy of the GNU Lesser General Public
17 License along with the GNU C Library; if not, see
18 <http://www.gnu.org/licenses/>. */
26 pthread_mutex_setprioceiling (pthread_mutex_t
*mutex
, int prioceiling
,
29 /* The low bits of __kind aren't ever changed after pthread_mutex_init,
30 so we don't need a lock yet. */
31 if ((mutex
->__data
.__kind
& PTHREAD_MUTEX_PRIO_PROTECT_NP
) == 0)
34 if (__sched_fifo_min_prio
== -1)
35 __init_sched_fifo_prio ();
37 if (__builtin_expect (prioceiling
< __sched_fifo_min_prio
, 0)
38 || __builtin_expect (prioceiling
> __sched_fifo_max_prio
, 0)
39 || __builtin_expect ((prioceiling
40 & (PTHREAD_MUTEXATTR_PRIO_CEILING_MASK
41 >> PTHREAD_MUTEXATTR_PRIO_CEILING_SHIFT
))
45 /* Check whether we already hold the mutex. */
47 int kind
= PTHREAD_MUTEX_TYPE (mutex
);
48 if (mutex
->__data
.__owner
== THREAD_GETMEM (THREAD_SELF
, tid
))
50 if (kind
== PTHREAD_MUTEX_PP_ERRORCHECK_NP
)
53 if (kind
== PTHREAD_MUTEX_PP_RECURSIVE_NP
)
57 int oldval
= mutex
->__data
.__lock
;
61 /* Need to lock the mutex, but without obeying the priority
63 int ceilval
= (oldval
& PTHREAD_MUTEX_PRIO_CEILING_MASK
);
65 oldval
= atomic_compare_and_exchange_val_acq (&mutex
->__data
.__lock
,
66 ceilval
| 1, ceilval
);
67 if (oldval
== ceilval
)
73 = atomic_compare_and_exchange_val_acq (&mutex
->__data
.__lock
,
77 if ((oldval
& PTHREAD_MUTEX_PRIO_CEILING_MASK
) != ceilval
)
80 if (oldval
!= ceilval
)
81 lll_futex_wait (&mutex
->__data
.__lock
, ceilval
| 2,
82 PTHREAD_MUTEX_PSHARED (mutex
));
84 while (atomic_compare_and_exchange_val_acq (&mutex
->__data
.__lock
,
88 if ((oldval
& PTHREAD_MUTEX_PRIO_CEILING_MASK
) != ceilval
)
93 int oldprio
= (oldval
& PTHREAD_MUTEX_PRIO_CEILING_MASK
)
94 >> PTHREAD_MUTEX_PRIO_CEILING_SHIFT
;
97 int ret
= __pthread_tpp_change_priority (oldprio
, prioceiling
);
102 if (old_ceiling
!= NULL
)
103 *old_ceiling
= oldprio
;
107 newlock
= (mutex
->__data
.__lock
& ~PTHREAD_MUTEX_PRIO_CEILING_MASK
);
108 mutex
->__data
.__lock
= newlock
109 | (prioceiling
<< PTHREAD_MUTEX_PRIO_CEILING_SHIFT
);
110 atomic_full_barrier ();
112 lll_futex_wake (&mutex
->__data
.__lock
, INT_MAX
,
113 PTHREAD_MUTEX_PSHARED (mutex
));