Lines Matching full:barrier

162 	pthread_barrier_t *barrier = (pthread_barrier_t *)arg;
166 	pthread_barrier_wait(barrier);
175 static int run_test_threads(pthread_t *threads, pthread_barrier_t *barrier)
179 	pthread_barrier_wait(barrier);
186 static int run_stress_test(int fd, pthread_t *threads, pthread_barrier_t *barrier)
194 	ret = run_test_threads(threads, barrier);
225 	pthread_barrier_t barrier;
234 	pthread_barrier_init(&barrier, NULL, NUM_THREADS + 1);
257 		if (pthread_create(&threads[i], NULL, test_thread, &barrier)) {
263 	ret = run_stress_test(fd, threads, &barrier);
270 	pthread_barrier_destroy(&barrier);