rapl_plot.c

Go to the documentation of this file.

 
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
 
#include "papi.h"
 
#define MAX_EVENTS 128
 
char events[MAX_EVENTS][BUFSIZ];
char units[MAX_EVENTS][BUFSIZ];
int data_type[MAX_EVENTS];
char filenames[MAX_EVENTS][BUFSIZ];
 
FILE *fff[MAX_EVENTS];
 
static int num_events=0;
 
int main (int argc, char **argv)
{
 
    int retval,cid,rapl_cid=-1,numcmp;
    int EventSet = PAPI_NULL;
    long long values[MAX_EVENTS];
    int i,code,enum_retval;
    PAPI_event_info_t evinfo;
    const PAPI_component_info_t *cmpinfo = NULL;
    long long start_time,before_time,after_time;
    double elapsed_time,total_time;
    char event_name[BUFSIZ];
 
    /* PAPI Initialization */
    retval = PAPI_library_init( PAPI_VER_CURRENT );
    if ( retval != PAPI_VER_CURRENT ) {
        fprintf(stderr,"PAPI_library_init failed\n");
        exit(1);
    }
 
    numcmp = PAPI_num_components();
 
    for(cid=0; cid<numcmp; cid++) {
 
        if ( (cmpinfo = PAPI_get_component_info(cid)) == NULL) {
            fprintf(stderr,"PAPI_get_component_info failed\n");
            exit(1);
        }
 
        if (strstr(cmpinfo->name,"rapl")) {
            rapl_cid=cid;
            printf("Found rapl component at cid %d\n", rapl_cid);
 
            if (cmpinfo->disabled) {
                fprintf(stderr,"No rapl events found: %s\n",
                        cmpinfo->disabled_reason);
                exit(1);
            }
            break;
        }
    }
 
    /* Component not found */
    if (cid==numcmp) {
        fprintf(stderr,"No rapl component found\n");
        exit(1);
    }
 
    /* Find Events */
    code = PAPI_NATIVE_MASK;
 
    enum_retval = PAPI_enum_cmp_event( &code, PAPI_ENUM_FIRST, cid );
 
    while ( enum_retval == PAPI_OK ) {
 
        retval = PAPI_event_code_to_name( code, event_name );
        if ( retval != PAPI_OK ) {
            printf("Error translating %#x\n",code);
            exit(1);
        }
 
        printf("Found: %s\n",event_name);
        strncpy(events[num_events],event_name,BUFSIZ);
        sprintf(filenames[num_events],"results.%s",event_name);
 
 
        /* Find additional event information: unit, data type */
        retval = PAPI_get_event_info(code, &evinfo);
        if (retval != PAPI_OK) {
            printf("Error getting event info for %#x\n",code);
            exit(1);
        }
 
        strncpy(units[num_events],evinfo.units,sizeof(units[0])-1);
        /* buffer must be null terminated to safely use strstr operation on it below */
        units[num_events][sizeof(units[0])-1] = '\0';
 
        data_type[num_events] = evinfo.data_type;
 
        num_events++;
 
        if (num_events==MAX_EVENTS) {
            printf("Too many events! %d\n",num_events);
            exit(1);
        }
 
        enum_retval = PAPI_enum_cmp_event( &code, PAPI_ENUM_EVENTS, cid );
 
    }
 
 
 
    if (num_events==0) {
        printf("Error!  No RAPL events found!\n");
        exit(1);
    }
 
    /* Open output files */
    for(i=0;i<num_events;i++) {
        fff[i]=fopen(filenames[i],"w");
        if (fff[i]==NULL) {
            fprintf(stderr,"Could not open %s\n",filenames[i]);
            exit(1);
        }
    }
 
 
    /* Create EventSet */
    retval = PAPI_create_eventset( &EventSet );
    if (retval != PAPI_OK) {
        fprintf(stderr,"Error creating eventset!\n");
    }
 
    for(i=0;i<num_events;i++) {
 
        retval = PAPI_add_named_event( EventSet, events[i] );
        if (retval != PAPI_OK) {
            fprintf(stderr,"Error adding event %s\n",events[i]);
        }
    }
 
 
 
    start_time=PAPI_get_real_nsec();
 
    while(1) {
 
        /* Start Counting */
        before_time=PAPI_get_real_nsec();
        retval = PAPI_start( EventSet);
        if (retval != PAPI_OK) {
            fprintf(stderr,"PAPI_start() failed\n");
            exit(1);
        }
 
 
        usleep(100000);
 
        /* Stop Counting */
        after_time=PAPI_get_real_nsec();
        retval = PAPI_stop( EventSet, values);
        if (retval != PAPI_OK) {
            fprintf(stderr, "PAPI_start() failed\n");
        }
 
        total_time=((double)(after_time-start_time))/1.0e9;
        elapsed_time=((double)(after_time-before_time))/1.0e9;
 
        for(i=0;i<num_events;i++) {
 
 
            if (!strstr(events[i],"ENERGY")) {
 
                /* Scaled fixed value */
                if (data_type[i] == PAPI_DATATYPE_FP64) {
 
                    union {
                        long long ll;
                        double fp;
                    } result;
 
                    result.ll=values[i];
 
 
                    fprintf(fff[i],"%.4f  %.3f  (* %s in (%s) *)\n",
                            total_time,
                            result.fp, 
                            events[i], units[i] );
 
                } 
                /* Fixed value counts */
                else if (data_type[i] == PAPI_DATATYPE_UINT64) {
 
                    fprintf(fff[i],"%.4f  %lld  (* %s *)\n",
                            total_time,
                            values[i], 
                            events[i] );
 
                }
            }
 
            /* Energy measurement counts */
            else if (strstr(events[i],"ENERGY_CNT")) {  
 
                fprintf(fff[i],"%.4f  %lld  (* %s *)\n",
                        total_time,
                        values[i], 
                        events[i] );
 
            }
 
            /* Scaled energy measurements */
            else {
                fprintf(fff[i],"%.4f  %.3f %s  %.3f %s  (* Average Power for %s *)\n",
                        total_time,
                        ((double)values[i]/1.0e9), "J",
                        ((double)values[i]/1.0e9)/elapsed_time, "W", 
                        events[i] );
            };
 
            fflush(fff[i]);
        }
    }
 
    return 0;
}