fluencelabs/musl
1
0
Fork 0
mirror of https://github.com/fluencelabs/musl synced 2025-06-30 15:11:55 +00:00
Code Issues Projects Releases Wiki Activity

initial check-in, version 0.5.0

Browse Source
This commit is contained in:
Rich Felker
2011-02-12 00:22:29 -05:00
commit 0b44a0315b
1021 changed files with 45711 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
src/thread/pthread_barrier_wait.c Normal file
View File

@ -0,0 +1,31 @@
#include "pthread_impl.h"
int pthread_barrier_wait(pthread_barrier_t *b)
{
int cur;
/* Trivial case: count was set at 1 */
if (!b->__limit) return PTHREAD_BARRIER_SERIAL_THREAD;
/* Wait for anyone still suspended at previous use of barrier */
while ((cur=b->__left))
__wait(&b->__left, &b->__waiters, cur, 0);
/* If we are the last to reach barrier, reset it and wake others */
if (a_fetch_add(&b->__count, 1) == b->__limit) {
b->__left = b->__limit;
b->__count = 0;
__wake(&b->__count, -1, 0);
return PTHREAD_BARRIER_SERIAL_THREAD;
}
/* Wait for our peers to reach the barrier */
while ((cur=b->__count))
__wait(&b->__count, 0, cur, 0);
/* If we're the last to wake up and barrier is awaiting reuse */
if (a_fetch_add(&b->__left, -1) == 1 && b->__waiters)
__wake(&b->__left, -1, 0);
return 0;
}