#include <stdio.h>

#include <stdlib.h>

#include <unistd.h>

#include <pthread.h>

#include "papi.h"

#include "papi_test.h"

#define NITER 2000

void *

Thread( void *data )

{

	int ret, evtset;

	( void ) data;

	if ( ( ret = PAPI_register_thread(  ) ) != PAPI_OK )

		test_fail( __FILE__, __LINE__, "PAPI_thread_init", ret );

	evtset = PAPI_NULL;

	if ( ( ret = PAPI_create_eventset( &evtset ) ) != PAPI_OK )

		test_fail( __FILE__, __LINE__, "PAPI_create_eventset", ret );

	if ( ( ret = PAPI_destroy_eventset( &evtset ) ) != PAPI_OK )

		test_fail( __FILE__, __LINE__, "PAPI_destroy_eventset", ret );

	if ( ( ret = PAPI_unregister_thread(  ) ) != PAPI_OK )

		test_fail( __FILE__, __LINE__, "PAPI_unregister_thread", ret );

	return ( NULL );

}

int

main( int argc, char *argv[] )

{

	int j;

	pthread_t *th = NULL;

	pthread_attr_t attr;

	int ret;

	long nthr;

	tests_quiet( argc, argv );	/*Set TESTS_QUIET variable */

	ret = PAPI_library_init( PAPI_VER_CURRENT );

	if ( ret != PAPI_VER_CURRENT )

		test_fail( __FILE__, __LINE__, "PAPI_library_init", ret );

	if ( ( ret =

		   PAPI_thread_init( ( unsigned

							   long ( * )( void ) ) ( pthread_self ) ) ) !=

		 PAPI_OK )

		test_fail( __FILE__, __LINE__, "PAPI_thread_init", ret );

	pthread_attr_init( &attr );

#ifdef PTHREAD_CREATE_UNDETACHED

	pthread_attr_setdetachstate( &attr, PTHREAD_CREATE_UNDETACHED );

#endif

#ifdef PTHREAD_SCOPE_SYSTEM

	ret = pthread_attr_setscope( &attr, PTHREAD_SCOPE_SYSTEM );

	if ( ret != 0 )

	   test_skip( __FILE__, __LINE__, "pthread_attr_setscope", ret );

#endif

	nthr = NITER;

	if ( !TESTS_QUIET ) {

		printf( "Creating %d threads for %d iterations each of:\n",

				( int ) nthr, 1 );

		printf( "\tregister\n" );

		printf( "\tcreate_eventset\n" );

		printf( "\tdestroy_eventset\n" );

		printf( "\tunregister\n" );

	}

	th = ( pthread_t * ) malloc( ( size_t ) nthr * sizeof ( pthread_t ) );

	if ( th == NULL )

		test_fail( __FILE__, __LINE__, "malloc", PAPI_ESYS );

	for ( j = 0; j < nthr; j++ ) {

		ret = pthread_create( &th[j], &attr, &Thread, NULL );

		if ( ret ) {

			printf( "Failed to create thread: %d\n", j );

			if ( j < 10 )

				test_fail( __FILE__, __LINE__, "pthread_create", PAPI_ESYS );

			printf( "Continuing test with %d threads.\n", j - 1 );

			nthr = j - 1;

			th = ( pthread_t * ) realloc( th,

										  ( size_t ) nthr *

										  sizeof ( pthread_t ) );

			break;

		}

	}

	for ( j = 0; j < nthr; j++ ) {

		pthread_join( th[j], NULL );

	}

	test_pass( __FILE__ );

	return 0;

}