smoke_tests/threads.c

Go to the documentation of this file.

#include <stdlib.h>
#include <unistd.h>
#include <stdio.h>
#include <pthread.h>
#include <papi.h>
#define NUM_PTHREADS 2
#define NUM_EVENTS 2 
 
void *
Thread(void *arg)
{
    int retval, i;
    long long       values[NUM_EVENTS];
    int             EventSet = PAPI_NULL;
    int             events[NUM_EVENTS];
    char            *EventName[] = { "PAPI_TOT_CYC", "PAPI_TOT_INS" };
    
    int thread;
    thread = *(int *) arg;
 
    retval = PAPI_register_thread(  );
    if ( retval != PAPI_OK ) {
        printf("ERROR: PAPI_register_thread: %d: %s\n", retval, PAPI_strerror(retval));
        exit(EXIT_FAILURE);
    }
 
    for( i = 0; i < NUM_EVENTS; i++ ) {
        retval = PAPI_event_name_to_code( EventName[i], &events[i] );
        if ( retval != PAPI_OK ) {
            printf("ERROR: PAPI_event_name_to_code: %d: %s\n", retval, PAPI_strerror(retval));
            exit(EXIT_FAILURE);
        }
    }
 
    retval = PAPI_create_eventset( &EventSet );
    if ( retval != PAPI_OK ) {
        printf("ERROR: PAPI_create_eventset: %d: %s\n", retval, PAPI_strerror(retval));
        exit(EXIT_FAILURE);
    }
 
    retval = PAPI_add_events( EventSet, events, NUM_EVENTS );
    if ( retval != PAPI_OK ) {
        printf("ERROR: PAPI_add_events: %d: %s\n", retval, PAPI_strerror(retval));
        exit(EXIT_FAILURE);
    }
 
    retval = PAPI_start( EventSet );
    if ( retval != PAPI_OK ) {
        printf("ERROR: PAPI_start: %d: %s\n", retval, PAPI_strerror(retval));
        exit(EXIT_FAILURE);
    }        
 
    // do work
    sleep(3);
                
    retval = PAPI_stop( EventSet, values );
    if ( retval != PAPI_OK ) {
        printf("ERROR: PAPI_stop: %d: %s\n", retval, PAPI_strerror(retval));
        exit(EXIT_FAILURE);
    }
                
    for( i = 0; i < NUM_EVENTS; i++ ) {           
        printf( "%12lld \t\t --> %s  (thread %d) \n", values[i],
                EventName[i], thread );
    }
 
    retval = PAPI_unregister_thread(  );
    if ( retval != PAPI_OK ) {
        printf("ERROR: PAPI_unregister_thread: %d: %s\n", retval, PAPI_strerror(retval));
        exit(EXIT_FAILURE);
    }
 
    return 0;
}
 
 
int main( int argc, char **argv )
{
    pthread_t tids[NUM_PTHREADS];
    int i, vals[NUM_PTHREADS];
    int retval, rc;
    void* retval2;
        
    /* Init PAPI library */
    retval = PAPI_library_init( PAPI_VER_CURRENT );
    if ( retval != PAPI_VER_CURRENT ) { 
        printf("ERROR: PAPI_library_init: %d: %s\n", retval, PAPI_strerror(retval) );
        exit(EXIT_FAILURE);
    } else {
        printf ( "PAPI_VERSION     : %4d %6d %7d\n",
                 PAPI_VERSION_MAJOR ( PAPI_VERSION ),
                 PAPI_VERSION_MINOR ( PAPI_VERSION ),
                 PAPI_VERSION_REVISION ( PAPI_VERSION ) );
    }
            
    retval = PAPI_thread_init( ( unsigned long ( * )( void ) )( pthread_self ) );
    if ( retval != PAPI_OK ) { 
        printf("ERROR: PAPI_thread_init: %d: %s\n", retval, PAPI_strerror(retval) );
        exit(EXIT_FAILURE);
    }
    
    for ( i = 0; i < NUM_PTHREADS; i++) {
        vals[i] = i;
        retval = pthread_create( &tids[i], NULL, Thread, &vals[i] );
        if ( retval != 0 ) {
            printf("ERROR: pthread_create: %d\n", retval );
            exit(EXIT_FAILURE);
        }
    }
 
    for ( i = 0; i < NUM_PTHREADS; i++) {
        printf("Trying to join with tid %d\n", i);
        retval = pthread_join(tids[i], &retval2);
        if ( retval != 0 ) {
            printf("ERROR: pthread_join: %d\n", retval );
            exit(EXIT_FAILURE);
        } else {
            printf("Joined with tid %d\n", i);
        }
    }
    
    PAPI_shutdown();
    return EXIT_SUCCESS;
}