1 #include "iwth.h"
2 #include <errno.h>
3
4 #ifdef __APPLE__
5
6 #ifndef __unused
7 #define __unused __attribute__((unused))
8 #endif
9
pthread_barrierattr_init(pthread_barrierattr_t * attr __unused)10 int pthread_barrierattr_init(pthread_barrierattr_t *attr __unused) {
11 return 0;
12 }
13
pthread_barrierattr_destroy(pthread_barrierattr_t * attr __unused)14 int pthread_barrierattr_destroy(pthread_barrierattr_t *attr __unused) {
15 return 0;
16 }
17
pthread_barrierattr_getpshared(const pthread_barrierattr_t * restrict attr __unused,int * restrict pshared)18 int pthread_barrierattr_getpshared(
19 const pthread_barrierattr_t* restrict attr __unused,
20 int* restrict pshared) {
21 *pshared = PTHREAD_PROCESS_PRIVATE;
22 return 0;
23 }
24
pthread_barrierattr_setpshared(pthread_barrierattr_t * attr __unused,int pshared)25 int pthread_barrierattr_setpshared(
26 pthread_barrierattr_t *attr __unused,
27 int pshared) {
28 if (pshared != PTHREAD_PROCESS_PRIVATE) {
29 errno = EINVAL;
30 return -1;
31 }
32 return 0;
33 }
34
pthread_barrier_init(pthread_barrier_t * restrict barrier,const pthread_barrierattr_t * restrict attr __unused,unsigned count)35 int pthread_barrier_init(
36 pthread_barrier_t* restrict barrier,
37 const pthread_barrierattr_t* restrict attr __unused,
38 unsigned count) {
39 if (count == 0) {
40 errno = EINVAL;
41 return -1;
42 }
43
44 if (pthread_mutex_init(&barrier->mutex, 0) < 0) {
45 return -1;
46 }
47 if (pthread_cond_init(&barrier->cond, 0) < 0) {
48 int errno_save = errno;
49 pthread_mutex_destroy(&barrier->mutex);
50 errno = errno_save;
51 return -1;
52 }
53
54 barrier->limit = count;
55 barrier->count = 0;
56 barrier->phase = 0;
57
58 return 0;
59 }
60
pthread_barrier_destroy(pthread_barrier_t * barrier)61 int pthread_barrier_destroy(pthread_barrier_t *barrier) {
62 pthread_mutex_destroy(&barrier->mutex);
63 pthread_cond_destroy(&barrier->cond);
64 return 0;
65 }
66
pthread_barrier_wait(pthread_barrier_t * barrier)67 int pthread_barrier_wait(pthread_barrier_t *barrier) {
68 pthread_mutex_lock(&barrier->mutex);
69 barrier->count++;
70 if (barrier->count >= barrier->limit) {
71 barrier->phase++;
72 barrier->count = 0;
73 pthread_cond_broadcast(&barrier->cond);
74 pthread_mutex_unlock(&barrier->mutex);
75 return PTHREAD_BARRIER_SERIAL_THREAD;
76 } else {
77 unsigned phase = barrier->phase;
78 do {
79 pthread_cond_wait(&barrier->cond, &barrier->mutex);
80 } while (phase == barrier->phase);
81 pthread_mutex_unlock(&barrier->mutex);
82 return 0;
83 }
84 }
85
86 #endif /* __APPLE__ */
87