1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
|
/* $OpenBSD: barrier.c,v 1.1 2012/04/11 18:39:24 pirofti Exp $ */
/* Paul Irofti <pirofti@openbsd.org>, 2012. Public Domain. */
#include <stdio.h>
#include <pthread.h>
#include <errno.h>
#include "test.h"
void *
foo(void *arg)
{
int rc = 0;
pthread_barrier_t b = (pthread_barrier_t)arg;
rc = pthread_barrier_wait(&b);
if (rc != 0 && rc != PTHREAD_BARRIER_SERIAL_THREAD)
PANIC("pthread_barrier_wait returned %d", rc);
return NULL;
}
int main()
{
int i;
pthread_t thr[10];
pthread_barrier_t b;
pthread_barrierattr_t attr;
CHECKr(pthread_barrierattr_init(&attr));
CHECKr(pthread_barrierattr_getpshared(&attr, &i));
_CHECK(i, == PTHREAD_PROCESS_PRIVATE, strerror(_x));
CHECKr(pthread_barrierattr_setpshared(&attr, i));
_CHECK(pthread_barrierattr_setpshared(&attr, PTHREAD_PROCESS_SHARED), == ENOTSUP, strerror(_x));
CHECKr(pthread_barrier_init(&b, &attr, 10));
for (i = 0; i < 10; i++) {
printf("Thread %d started\n", i);
CHECKr(pthread_create(&thr[i], NULL, foo, (void *)b));
}
for (i = 0; i < 10; i++) {
CHECKr(pthread_join(thr[i], NULL));
}
CHECKr(pthread_barrierattr_destroy(&attr));
CHECKr(pthread_barrier_destroy(&b));
SUCCEED;
}
|
