profile_pthreads.c

Go to the documentation of this file.

/* This file performs the following test: profile for pthreads */

#include <pthread.h>
#include "papi_test.h"

extern int TESTS_QUIET;                /* Declared in test_utils.c */

#define THR 1000000
#define FLOPS 100000000

unsigned int length;
caddr_t my_start, my_end;

void *
Thread( void *arg )
{
    int retval, num_tests = 1, i;
    int EventSet1 = PAPI_NULL, mask1, PAPI_event;
    int num_events1;
    long long **values;
    long long elapsed_us, elapsed_cyc;
    unsigned short *profbuf;
    char event_name[PAPI_MAX_STR_LEN];

    retval = PAPI_register_thread(  );
    if ( retval != PAPI_OK )
        test_fail( __FILE__, __LINE__, "PAPI_register_thread", retval );
    profbuf = ( unsigned short * ) malloc( length * sizeof ( unsigned short ) );
    if ( profbuf == NULL )
        exit( 1 );
    memset( profbuf, 0x00, length * sizeof ( unsigned short ) );

    /* add PAPI_TOT_CYC and one of the events in PAPI_FP_INS, PAPI_FP_OPS or
       PAPI_TOT_INS, depends on the availability of the event on the
       platform */
    EventSet1 =
        add_two_nonderived_events( &num_events1, &PAPI_event, &mask1 );

    values = allocate_test_space( num_tests, num_events1 );

    if ( ( retval =
           PAPI_event_code_to_name( PAPI_event, event_name ) ) != PAPI_OK )
        test_fail( __FILE__, __LINE__, "PAPI_event_code_to_name", retval );

    elapsed_us = PAPI_get_real_usec(  );

    elapsed_cyc = PAPI_get_real_cyc(  );

    retval = PAPI_profil( profbuf, length, my_start, 65536,
                          EventSet1, PAPI_event, THR, PAPI_PROFIL_POSIX );
    if ( retval )
        test_fail( __FILE__, __LINE__, "PAPI_profil", retval );

    if ( ( retval = PAPI_start( EventSet1 ) ) != PAPI_OK )
        test_fail( __FILE__, __LINE__, "PAPI_start", retval );

    do_flops( *( int * ) arg );

    if ( ( retval = PAPI_stop( EventSet1, values[0] ) ) != PAPI_OK )
        test_fail( __FILE__, __LINE__, "PAPI_stop", retval );

    elapsed_us = PAPI_get_real_usec(  ) - elapsed_us;

    elapsed_cyc = PAPI_get_real_cyc(  ) - elapsed_cyc;

    /* to remove the profile flag */
    retval = PAPI_profil( profbuf, length, my_start, 65536,
                          EventSet1, PAPI_event, 0, PAPI_PROFIL_POSIX );
    if ( retval )
        test_fail( __FILE__, __LINE__, "PAPI_profil", retval );


    remove_test_events( &EventSet1, mask1 );

    if ( !TESTS_QUIET ) {
        if ( mask1 == 0x3 ) {
            printf( "Thread 0x%x PAPI_TOT_INS : \t%lld\n",
                    ( int ) pthread_self(  ), ( values[0] )[0] );
        } else {
            printf( "Thread 0x%x PAPI_FP_INS : \t%lld\n",
                    ( int ) pthread_self(  ), ( values[0] )[0] );
        }
        printf( "Thread 0x%x PAPI_TOT_CYC: \t%lld\n", ( int ) pthread_self(  ),
                ( values[0] )[1] );
        printf( "Thread 0x%x Real usec   : \t%lld\n", ( int ) pthread_self(  ),
                elapsed_us );
        printf( "Thread 0x%x Real cycles : \t%lld\n", ( int ) pthread_self(  ),
                elapsed_cyc );

        printf( "Test case: PAPI_profil() for pthreads\n" );
        printf( "----Profile buffer for Thread 0x%x---\n",
                ( int ) pthread_self(  ) );
        for ( i = 0; i < ( int ) length; i++ ) {
            if ( profbuf[i] )
                printf( "0x%lx\t%d\n", ( unsigned long ) ( my_start + 2 * i ),
                        profbuf[i] );
        }
    }
    for ( i = 0; i < ( int ) length; i++ )
        if ( profbuf[i] )
            break;

    if ( i >= ( int ) length )
        test_fail( __FILE__, __LINE__, "No information in buffers", 1 );
    free_test_space( values, num_tests );

    retval = PAPI_unregister_thread(  );
    if ( retval != PAPI_OK )
        test_fail( __FILE__, __LINE__, "PAPI_unregister_thread", retval );
    return ( NULL );
}

int
main( int argc, char **argv )
{
    pthread_t id[NUM_THREADS];
    int flops[NUM_THREADS];
    int i, rc, retval;
    pthread_attr_t attr;
    long long elapsed_us, elapsed_cyc;
    const PAPI_exe_info_t *prginfo = NULL;

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

    if ( ( retval =
           PAPI_library_init( PAPI_VER_CURRENT ) ) != PAPI_VER_CURRENT )
        test_fail( __FILE__, __LINE__, "PAPI_library_init", retval );
    if ( ( retval =
           PAPI_thread_init( ( unsigned
                               long ( * )( void ) ) ( pthread_self ) ) ) !=
         PAPI_OK ) {
        if ( retval == PAPI_ECMP )
            test_skip( __FILE__, __LINE__, "PAPI_thread_init", retval );
        else
            test_fail( __FILE__, __LINE__, "PAPI_thread_init", retval );
    }
    if ( ( prginfo = PAPI_get_executable_info(  ) ) == NULL ) {
        retval = 1;
        test_fail( __FILE__, __LINE__, "PAPI_get_executable_info", retval );
    }
    my_start = prginfo->address_info.text_start;
    my_end = prginfo->address_info.text_end;
    length = ( unsigned int ) ( my_end - my_start );

    elapsed_us = PAPI_get_real_usec(  );

    elapsed_cyc = PAPI_get_real_cyc(  );

    pthread_attr_init( &attr );
#ifdef PTHREAD_CREATE_UNDETACHED
    pthread_attr_setdetachstate( &attr, PTHREAD_CREATE_UNDETACHED );
#endif
#ifdef PTHREAD_SCOPE_SYSTEM
    retval = pthread_attr_setscope( &attr, PTHREAD_SCOPE_SYSTEM );
    if ( retval != 0 )
        test_skip( __FILE__, __LINE__, "pthread_attr_setscope", retval );
#endif

    for ( i = 0; i < NUM_THREADS; i++ ) {
        flops[i] = FLOPS * ( i + 1 );
        rc = pthread_create( &id[i], &attr, Thread, ( void * ) &flops[i] );
        if ( rc )
            return ( FAILURE );
    }
    for ( i = 0; i < NUM_THREADS; i++ )
        pthread_join( id[i], NULL );

    pthread_attr_destroy( &attr );

    elapsed_cyc = PAPI_get_real_cyc(  ) - elapsed_cyc;

    elapsed_us = PAPI_get_real_usec(  ) - elapsed_us;

    if ( !TESTS_QUIET ) {
        printf( "Master real usec   : \t%lld\n", elapsed_us );
        printf( "Master real cycles : \t%lld\n", elapsed_cyc );
    }

    test_pass( __FILE__, NULL, 0 );
    pthread_exit( NULL );
    exit( 1 );
}