fluencelabs/musl
1
0
Fork 0
mirror of https://github.com/fluencelabs/musl synced 2025-07-30 22:01:57 +00:00
Code Issues Projects Releases Wiki Activity

reorganize pthread data structures and move the definitions to alltypes.h

Browse Source 
this allows sys/types.h to provide the pthread types, as required by
POSIX. this design also facilitates forcing ABI-compatible sizes in
the arch-specific alltypes.h, while eliminating the need for
developers changing the internals of the pthread types to poke around
with arch-specific headers they may not be able to test.
This commit is contained in:
Rich Felker
2011-02-17 17:16:20 -05:00
parent 4fd159568a
commit e882756311
28 changed files with 158 additions and 128 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
src/thread/pthread_barrier_wait.c
View File

@@ -5,27 +5,27 @@ 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;
if (!b->_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);
while ((cur=b->_b_left))
__wait(&b->_b_left, &b->_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);
if (a_fetch_add(&b->_b_count, 1) == b->_b_limit) {
b->_b_left = b->_b_limit;
b->_b_count = 0;
__wake(&b->_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);
while ((cur=b->_b_count))
__wait(&b->_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);
if (a_fetch_add(&b->_b_left, -1) == 1 && b->_b_waiters)
__wake(&b->_b_left, -1, 0);
return 0;
}