Lines Matching refs:barrier
176 pthread_barrier_t *barrier = (pthread_barrier_t *)arg;
180 pthread_barrier_wait(barrier);
189 static int run_test_threads(pthread_t *threads, pthread_barrier_t *barrier)
193 pthread_barrier_wait(barrier);
200 static int run_stress_test(int fd, pthread_t *threads, pthread_barrier_t *barrier)
208 ret = run_test_threads(threads, barrier);
239 pthread_barrier_t barrier;
248 pthread_barrier_init(&barrier, NULL, NUM_THREADS + 1);
271 if (pthread_create(&threads[i], NULL, test_thread, &barrier)) {
277 ret = run_stress_test(fd, threads, &barrier);
284 pthread_barrier_destroy(&barrier);