X-Git-Url: http://nsz.repo.hu/git/?a=blobdiff_plain;f=src%2Fthread%2Fpthread_mutex_trylock.c;h=850fcb90119f972bc30afd57b0f8a0d0166d9de2;hb=b092f1c5fa9c048e12d002c7b972df5ecbe96d1d;hp=f48aaadec3c761e83b42ad4052417972d8b5c30d;hpb=047e434ef5fd5437a74f98f63c40a77a683f7f3f;p=musl diff --git a/src/thread/pthread_mutex_trylock.c b/src/thread/pthread_mutex_trylock.c index f48aaade..850fcb90 100644 --- a/src/thread/pthread_mutex_trylock.c +++ b/src/thread/pthread_mutex_trylock.c @@ -1,40 +1,34 @@ #include "pthread_impl.h" -int pthread_mutex_trylock(pthread_mutex_t *m) +int __pthread_mutex_trylock_owner(pthread_mutex_t *m) { - int tid; - int own; - pthread_t self; - - if (m->_m_type == PTHREAD_MUTEX_NORMAL) - return (m->_m_lock || a_swap(&m->_m_lock, 1)) ? EBUSY : 0; + int old, own; + int type = m->_m_type & 15; + pthread_t self = __pthread_self(); + int tid = self->tid; - self = pthread_self(); - tid = self->tid | 0x80000000; - - if (m->_m_type >= 4) { + if (type >= 4) { if (!self->robust_list.off) - syscall2(__NR_set_robust_list, - (long)&self->robust_list, 3*sizeof(long)); + __syscall(SYS_set_robust_list, + &self->robust_list, 3*sizeof(long)); self->robust_list.off = (char*)&m->_m_lock-(char *)&m->_m_next; self->robust_list.pending = &m->_m_next; } - if (m->_m_lock == tid && (m->_m_type&3) == PTHREAD_MUTEX_RECURSIVE) { + old = m->_m_lock; + own = old & 0x7fffffff; + if (own == tid && (type&3) == PTHREAD_MUTEX_RECURSIVE) { if ((unsigned)m->_m_count >= INT_MAX) return EAGAIN; m->_m_count++; return 0; } - own = m->_m_lock; - if ((own && !(own & 0x40000000)) || a_cas(&m->_m_lock, own, tid)!=own) + if ((own && !(own & 0x40000000)) || a_cas(&m->_m_lock, old, tid)!=old) return EBUSY; - m->_m_count = 1; - - if (m->_m_type < 4) return 0; + if (type < 4) return 0; - if (m->_m_type >= 8) { + if (type >= 8) { m->_m_lock = 0; return ENOTRECOVERABLE; } @@ -45,9 +39,17 @@ int pthread_mutex_trylock(pthread_mutex_t *m) self->robust_list.head = &m->_m_next; self->robust_list.pending = 0; if (own) { + m->_m_count = 0; m->_m_type += 8; return EOWNERDEAD; } return 0; } + +int pthread_mutex_trylock(pthread_mutex_t *m) +{ + if ((m->_m_type&15) == PTHREAD_MUTEX_NORMAL) + return a_cas(&m->_m_lock, 0, EBUSY) & EBUSY; + return __pthread_mutex_trylock_owner(m); +}