mirror of
git://git.musl-libc.org/musl
synced 2024-12-18 12:45:11 +00:00
introduce namespace-safe rwlock aliases; use in pthread_key_create
commit 84d061d5a3
inadvertently
introduced namespace violations by using the pthread-namespace rwlock
functions in pthread_key_create, which is in turn used for C11 tss.
fix that and possible future uses of rwlocks elsewhere.
This commit is contained in:
parent
ba74a42cee
commit
639bcf251e
@ -18,5 +18,12 @@ hidden int __private_cond_signal(pthread_cond_t *, int);
|
|||||||
hidden int __pthread_cond_timedwait(pthread_cond_t *restrict, pthread_mutex_t *restrict, const struct timespec *restrict);
|
hidden int __pthread_cond_timedwait(pthread_cond_t *restrict, pthread_mutex_t *restrict, const struct timespec *restrict);
|
||||||
hidden int __pthread_key_create(pthread_key_t *, void (*)(void *));
|
hidden int __pthread_key_create(pthread_key_t *, void (*)(void *));
|
||||||
hidden int __pthread_key_delete(pthread_key_t);
|
hidden int __pthread_key_delete(pthread_key_t);
|
||||||
|
hidden int __pthread_rwlock_rdlock(pthread_rwlock_t *);
|
||||||
|
hidden int __pthread_rwlock_tryrdlock(pthread_rwlock_t *);
|
||||||
|
hidden int __pthread_rwlock_timedrdlock(pthread_rwlock_t *__restrict, const struct timespec *__restrict);
|
||||||
|
hidden int __pthread_rwlock_wrlock(pthread_rwlock_t *);
|
||||||
|
hidden int __pthread_rwlock_trywrlock(pthread_rwlock_t *);
|
||||||
|
hidden int __pthread_rwlock_timedwrlock(pthread_rwlock_t *__restrict, const struct timespec *__restrict);
|
||||||
|
hidden int __pthread_rwlock_unlock(pthread_rwlock_t *);
|
||||||
|
|
||||||
#endif
|
#endif
|
||||||
|
@ -32,16 +32,16 @@ int __pthread_key_create(pthread_key_t *k, void (*dtor)(void *))
|
|||||||
/* Purely a sentinel value since null means slot is free. */
|
/* Purely a sentinel value since null means slot is free. */
|
||||||
if (!dtor) dtor = nodtor;
|
if (!dtor) dtor = nodtor;
|
||||||
|
|
||||||
pthread_rwlock_wrlock(&key_lock);
|
__pthread_rwlock_wrlock(&key_lock);
|
||||||
do {
|
do {
|
||||||
if (!keys[j]) {
|
if (!keys[j]) {
|
||||||
keys[next_key = *k = j] = dtor;
|
keys[next_key = *k = j] = dtor;
|
||||||
pthread_rwlock_unlock(&key_lock);
|
__pthread_rwlock_unlock(&key_lock);
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
} while ((j=(j+1)%PTHREAD_KEYS_MAX) != next_key);
|
} while ((j=(j+1)%PTHREAD_KEYS_MAX) != next_key);
|
||||||
|
|
||||||
pthread_rwlock_unlock(&key_lock);
|
__pthread_rwlock_unlock(&key_lock);
|
||||||
return EAGAIN;
|
return EAGAIN;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -57,9 +57,9 @@ int __pthread_key_delete(pthread_key_t k)
|
|||||||
__tl_unlock();
|
__tl_unlock();
|
||||||
__restore_sigs(&set);
|
__restore_sigs(&set);
|
||||||
|
|
||||||
pthread_rwlock_wrlock(&key_lock);
|
__pthread_rwlock_wrlock(&key_lock);
|
||||||
keys[k] = 0;
|
keys[k] = 0;
|
||||||
pthread_rwlock_unlock(&key_lock);
|
__pthread_rwlock_unlock(&key_lock);
|
||||||
|
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
@ -69,19 +69,19 @@ void __pthread_tsd_run_dtors()
|
|||||||
pthread_t self = __pthread_self();
|
pthread_t self = __pthread_self();
|
||||||
int i, j;
|
int i, j;
|
||||||
for (j=0; self->tsd_used && j<PTHREAD_DESTRUCTOR_ITERATIONS; j++) {
|
for (j=0; self->tsd_used && j<PTHREAD_DESTRUCTOR_ITERATIONS; j++) {
|
||||||
pthread_rwlock_rdlock(&key_lock);
|
__pthread_rwlock_rdlock(&key_lock);
|
||||||
self->tsd_used = 0;
|
self->tsd_used = 0;
|
||||||
for (i=0; i<PTHREAD_KEYS_MAX; i++) {
|
for (i=0; i<PTHREAD_KEYS_MAX; i++) {
|
||||||
void *val = self->tsd[i];
|
void *val = self->tsd[i];
|
||||||
void (*dtor)(void *) = keys[i];
|
void (*dtor)(void *) = keys[i];
|
||||||
self->tsd[i] = 0;
|
self->tsd[i] = 0;
|
||||||
if (val && dtor && dtor != nodtor) {
|
if (val && dtor && dtor != nodtor) {
|
||||||
pthread_rwlock_unlock(&key_lock);
|
__pthread_rwlock_unlock(&key_lock);
|
||||||
dtor(val);
|
dtor(val);
|
||||||
pthread_rwlock_rdlock(&key_lock);
|
__pthread_rwlock_rdlock(&key_lock);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
pthread_rwlock_unlock(&key_lock);
|
__pthread_rwlock_unlock(&key_lock);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -1,6 +1,8 @@
|
|||||||
#include "pthread_impl.h"
|
#include "pthread_impl.h"
|
||||||
|
|
||||||
int pthread_rwlock_rdlock(pthread_rwlock_t *rw)
|
int __pthread_rwlock_rdlock(pthread_rwlock_t *rw)
|
||||||
{
|
{
|
||||||
return pthread_rwlock_timedrdlock(rw, 0);
|
return __pthread_rwlock_timedrdlock(rw, 0);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
weak_alias(__pthread_rwlock_rdlock, pthread_rwlock_rdlock);
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
#include "pthread_impl.h"
|
#include "pthread_impl.h"
|
||||||
|
|
||||||
int pthread_rwlock_timedrdlock(pthread_rwlock_t *restrict rw, const struct timespec *restrict at)
|
int __pthread_rwlock_timedrdlock(pthread_rwlock_t *restrict rw, const struct timespec *restrict at)
|
||||||
{
|
{
|
||||||
int r, t;
|
int r, t;
|
||||||
|
|
||||||
@ -10,7 +10,7 @@ int pthread_rwlock_timedrdlock(pthread_rwlock_t *restrict rw, const struct times
|
|||||||
int spins = 100;
|
int spins = 100;
|
||||||
while (spins-- && rw->_rw_lock && !rw->_rw_waiters) a_spin();
|
while (spins-- && rw->_rw_lock && !rw->_rw_waiters) a_spin();
|
||||||
|
|
||||||
while ((r=pthread_rwlock_tryrdlock(rw))==EBUSY) {
|
while ((r=__pthread_rwlock_tryrdlock(rw))==EBUSY) {
|
||||||
if (!(r=rw->_rw_lock) || (r&0x7fffffff)!=0x7fffffff) continue;
|
if (!(r=rw->_rw_lock) || (r&0x7fffffff)!=0x7fffffff) continue;
|
||||||
t = r | 0x80000000;
|
t = r | 0x80000000;
|
||||||
a_inc(&rw->_rw_waiters);
|
a_inc(&rw->_rw_waiters);
|
||||||
@ -21,3 +21,5 @@ int pthread_rwlock_timedrdlock(pthread_rwlock_t *restrict rw, const struct times
|
|||||||
}
|
}
|
||||||
return r;
|
return r;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
weak_alias(__pthread_rwlock_timedrdlock, pthread_rwlock_timedrdlock);
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
#include "pthread_impl.h"
|
#include "pthread_impl.h"
|
||||||
|
|
||||||
int pthread_rwlock_timedwrlock(pthread_rwlock_t *restrict rw, const struct timespec *restrict at)
|
int __pthread_rwlock_timedwrlock(pthread_rwlock_t *restrict rw, const struct timespec *restrict at)
|
||||||
{
|
{
|
||||||
int r, t;
|
int r, t;
|
||||||
|
|
||||||
@ -10,7 +10,7 @@ int pthread_rwlock_timedwrlock(pthread_rwlock_t *restrict rw, const struct times
|
|||||||
int spins = 100;
|
int spins = 100;
|
||||||
while (spins-- && rw->_rw_lock && !rw->_rw_waiters) a_spin();
|
while (spins-- && rw->_rw_lock && !rw->_rw_waiters) a_spin();
|
||||||
|
|
||||||
while ((r=pthread_rwlock_trywrlock(rw))==EBUSY) {
|
while ((r=__pthread_rwlock_trywrlock(rw))==EBUSY) {
|
||||||
if (!(r=rw->_rw_lock)) continue;
|
if (!(r=rw->_rw_lock)) continue;
|
||||||
t = r | 0x80000000;
|
t = r | 0x80000000;
|
||||||
a_inc(&rw->_rw_waiters);
|
a_inc(&rw->_rw_waiters);
|
||||||
@ -21,3 +21,5 @@ int pthread_rwlock_timedwrlock(pthread_rwlock_t *restrict rw, const struct times
|
|||||||
}
|
}
|
||||||
return r;
|
return r;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
weak_alias(__pthread_rwlock_timedwrlock, pthread_rwlock_timedwrlock);
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
#include "pthread_impl.h"
|
#include "pthread_impl.h"
|
||||||
|
|
||||||
int pthread_rwlock_tryrdlock(pthread_rwlock_t *rw)
|
int __pthread_rwlock_tryrdlock(pthread_rwlock_t *rw)
|
||||||
{
|
{
|
||||||
int val, cnt;
|
int val, cnt;
|
||||||
do {
|
do {
|
||||||
@ -11,3 +11,5 @@ int pthread_rwlock_tryrdlock(pthread_rwlock_t *rw)
|
|||||||
} while (a_cas(&rw->_rw_lock, val, val+1) != val);
|
} while (a_cas(&rw->_rw_lock, val, val+1) != val);
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
weak_alias(__pthread_rwlock_tryrdlock, pthread_rwlock_tryrdlock);
|
||||||
|
@ -1,7 +1,9 @@
|
|||||||
#include "pthread_impl.h"
|
#include "pthread_impl.h"
|
||||||
|
|
||||||
int pthread_rwlock_trywrlock(pthread_rwlock_t *rw)
|
int __pthread_rwlock_trywrlock(pthread_rwlock_t *rw)
|
||||||
{
|
{
|
||||||
if (a_cas(&rw->_rw_lock, 0, 0x7fffffff)) return EBUSY;
|
if (a_cas(&rw->_rw_lock, 0, 0x7fffffff)) return EBUSY;
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
weak_alias(__pthread_rwlock_trywrlock, pthread_rwlock_trywrlock);
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
#include "pthread_impl.h"
|
#include "pthread_impl.h"
|
||||||
|
|
||||||
int pthread_rwlock_unlock(pthread_rwlock_t *rw)
|
int __pthread_rwlock_unlock(pthread_rwlock_t *rw)
|
||||||
{
|
{
|
||||||
int val, cnt, waiters, new, priv = rw->_rw_shared^128;
|
int val, cnt, waiters, new, priv = rw->_rw_shared^128;
|
||||||
|
|
||||||
@ -16,3 +16,5 @@ int pthread_rwlock_unlock(pthread_rwlock_t *rw)
|
|||||||
|
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
weak_alias(__pthread_rwlock_unlock, pthread_rwlock_unlock);
|
||||||
|
@ -1,6 +1,8 @@
|
|||||||
#include "pthread_impl.h"
|
#include "pthread_impl.h"
|
||||||
|
|
||||||
int pthread_rwlock_wrlock(pthread_rwlock_t *rw)
|
int __pthread_rwlock_wrlock(pthread_rwlock_t *rw)
|
||||||
{
|
{
|
||||||
return pthread_rwlock_timedwrlock(rw, 0);
|
return __pthread_rwlock_timedwrlock(rw, 0);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
weak_alias(__pthread_rwlock_wrlock, pthread_rwlock_wrlock);
|
||||||
|
Loading…
Reference in New Issue
Block a user