| /* |
| * Test program that triggers pthread_barrier_wait() where each |
| * pthread_barrier_wait() call is invoked by another thread. This is the only |
| * test program that triggers the code guarded by if (q->thread_finished) in |
| * DRD_(barrier_pre_wait)(). |
| */ |
| |
| #define _GNU_SOURCE |
| |
| #include <assert.h> |
| #include <pthread.h> |
| #include <stdio.h> |
| #include <stdlib.h> |
| #include <unistd.h> |
| |
| static pthread_barrier_t* s_barrier; |
| |
| static void* thread(void* arg) |
| { |
| write(STDOUT_FILENO, ".", 1); |
| pthread_barrier_wait(s_barrier); |
| return NULL; |
| } |
| |
| int main(int argc, char** argv) |
| { |
| pthread_t *tid; |
| int barriers = argc > 1 ? atoi(argv[1]) : 20; |
| int barrier_participants = 2; |
| int thread_count = barriers * barrier_participants; |
| int res, i; |
| |
| s_barrier = malloc(sizeof(*s_barrier)); |
| res = pthread_barrier_init(s_barrier, NULL, barrier_participants); |
| assert(res == 0); |
| |
| tid = malloc(thread_count * sizeof(*tid)); |
| assert(tid); |
| for (i = 0; i < thread_count; i++) { |
| res = pthread_create(&tid[i], NULL, thread, NULL); |
| assert(res == 0); |
| } |
| for (i = 0; i < thread_count; i++) { |
| res = pthread_join(tid[i], NULL); |
| assert(res == 0); |
| } |
| free(tid); |
| |
| res = pthread_barrier_destroy(s_barrier); |
| assert(res == 0); |
| free(s_barrier); |
| s_barrier = NULL; |
| |
| write(STDOUT_FILENO, "\n", 1); |
| fprintf(stderr, "Done.\n"); |
| |
| return 0; |
| } |