Lines Matching refs:barrier
124 pthread_barrier_t *barrier = (pthread_barrier_t *)arg;
128 pthread_barrier_wait(barrier);
137 static int run_test_threads(pthread_t *threads, pthread_barrier_t *barrier)
141 pthread_barrier_wait(barrier);
148 static int run_stress_test(int fd, pthread_t *threads, pthread_barrier_t *barrier)
156 ret = run_test_threads(threads, barrier);
178 pthread_barrier_t barrier;
187 pthread_barrier_init(&barrier, NULL, NUM_THREADS + 1);
210 if (pthread_create(&threads[i], NULL, test_thread, &barrier)) {
216 ret = run_stress_test(fd, threads, &barrier);
223 pthread_barrier_destroy(&barrier);