X-Git-Url: http://nsz.repo.hu/git/?a=blobdiff_plain;f=src%2Fthread%2Fpthread_rwlock_unlock.c;h=9ae27ad2b3a76c05d4038b291469053bf61f62e2;hb=4554f155dd23a65fcdfd39f1d5af8af55ba37694;hp=f39117e743ee75c20a420f8ecfec1d336adb8d42;hpb=0b44a0315b47dd8eced9f3b7f31580cf14bbfc01;p=musl

diff --git a/src/thread/pthread_rwlock_unlock.c b/src/thread/pthread_rwlock_unlock.c
index f39117e7..9ae27ad2 100644
--- a/src/thread/pthread_rwlock_unlock.c
+++ b/src/thread/pthread_rwlock_unlock.c
@@ -1,17 +1,20 @@
 #include "pthread_impl.h"
 
-int pthread_rwlock_unlock(pthread_rwlock_t *rw)
+int __pthread_rwlock_unlock(pthread_rwlock_t *rw)
 {
-	struct pthread *self = pthread_self();
-	if (rw->__owner == self->tid) {
-		rw->__owner = 0;
-		a_store(&rw->__wrlock, 0);
-		if (rw->__waiters)
-			__wake(&rw->__wrlock, -1, 0);
-		return 0;
-	}
-	a_dec(&rw->__readers);
-	if (rw->__waiters && !rw->__readers)
-		__wake(&rw->__readers, 1, 0);
+	int val, cnt, waiters, new, priv = rw->_rw_shared^128;
+
+	do {
+		val = rw->_rw_lock;
+		cnt = val & 0x7fffffff;
+		waiters = rw->_rw_waiters;
+		new = (cnt == 0x7fffffff || cnt == 1) ? 0 : val-1;
+	} while (a_cas(&rw->_rw_lock, val, new) != val);
+
+	if (!new && (waiters || val<0))
+		__wake(&rw->_rw_lock, cnt, priv);
+
 	return 0;
 }
+
+weak_alias(__pthread_rwlock_unlock, pthread_rwlock_unlock);