/*
 * Copyright (c) 2002, Intel Corporation. All rights reserved.
 * This file is licensed under the GPL license.  For the full content
 * of this license, see the COPYING file at the top level of this
 * source tree.
 *
 * pthread_barrier_wait()
 *
 * When the required number of threads have called pthread_barrier_wait()
 * specifying the barrier, the constant PTHREAD_BARRIER_SERIAL_THREAD shall
 * be returned to one unspecified thread and zero shall be returned
 * to each of the remaining threads. At this point, the barrier shall
 * be reset to the state it had as a result of the most recent
 * pthread_barrier_init() function that referenced it.
 *
 * Steps:
 * 1. Main thread do the following for LOOP_NUM times
 * 2. In each loop, Main thread initialize barrier, with count set to THREAD_NUM
 * 3. Main create THREAD_NUM threads
 * 4. Each thread will call pthread_barrier_wait()
 * 5. When the last thread calls pthread_barrier_wait, only one thread will
 *    get PTHREAD_BARRIER_SERIAL_THREAD, all the other threads should get zero
 * 6. This holds true for every loop.
 *
 */

#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <signal.h>
#include "posixtest.h"

#define THREAD_NUM 5
#define LOOP_NUM 3

static pthread_barrier_t barrier;
static int serial;
static int normal_rt;
static pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;

static void *fn_chld(void *arg)
{
	int rc = 0;
	int thread_num = *(int *)arg;

	printf("child[%d]: barrier wait\n", thread_num);
	rc = pthread_barrier_wait(&barrier);
	if (rc != 0 && rc != PTHREAD_BARRIER_SERIAL_THREAD) {
		printf
		    ("Test FAILED: child[%d]: pthread_barrier_wait() get unexpected "
		     "return code : %d\n", thread_num, rc);
		exit(PTS_FAIL);
	} else if (rc == PTHREAD_BARRIER_SERIAL_THREAD) {
		serial++;
		printf("child[%d]: get PTHREAD_BARRIER_SERIAL_THREAD\n",
		       thread_num);
	} else {
		pthread_mutex_lock(&mutex);
		normal_rt++;
		pthread_mutex_unlock(&mutex);
	}

	pthread_exit(0);
	return NULL;
}

int main(void)
{
	pthread_t child_threads[THREAD_NUM];
	int cnt;
	int loop;

	printf("Initialize barrier with count = %d\n", THREAD_NUM);
	if (pthread_barrier_init(&barrier, NULL, THREAD_NUM) != 0) {
		printf("main: Error at pthread_barrier_init()\n");
		return PTS_UNRESOLVED;
	}

	for (loop = 0; loop < LOOP_NUM; loop++) {
		serial = 0;
		normal_rt = 0;
		printf("\n-Loop %d-\n", loop);

		printf("main: create %d child threads\n", THREAD_NUM);
		for (cnt = 0; cnt < THREAD_NUM; cnt++) {
			if (pthread_create
			    (&child_threads[cnt], NULL, fn_chld, &cnt) != 0) {
				printf("main: Error at %dth pthread_create()\n",
				       cnt);
				return PTS_UNRESOLVED;
			}

		}
		printf("main: wait for child threads to end\n");
		for (cnt = 0; cnt < THREAD_NUM; cnt++) {
			if (pthread_join(child_threads[cnt], NULL) != 0) {
				printf("main: Error at %dth pthread_join()\n",
				       cnt);
				exit(PTS_UNRESOLVED);
			}
		}

		if (serial != 1 || (serial + normal_rt) != THREAD_NUM) {
			printf
			    ("Test FAILED: On %d loop, PTHREAD_BARRIER_SERIAL_THREAD "
			     "should be returned to one unspecified thread\n",
			     loop);
			return PTS_FAIL;
		}

	}

	if (pthread_barrier_destroy(&barrier) != 0) {
		printf("Error at pthread_barrier_destroy()\n");
		return PTS_UNRESOLVED;
	}

	printf("\nTest PASSED\n");
	return PTS_PASS;
}