pthrtough2.c

Go to the documentation of this file.

#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 ) {
            free(th);
                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 );
    }
 
   free(th);
    test_pass( __FILE__ );
 
    return 0;
}