linux-io.c

Go to the documentation of this file.

 
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <inttypes.h>
 
/* Headers required by PAPI */
#include "papi.h"
#include "papi_internal.h"
#include "papi_vector.h"
#include "papi_memory.h"    /* defines papi_malloc(), etc. */
 
/* Declare our vector in advance */
/* This allows us to modify the component info */
papi_vector_t _io_vector;
 
// Maximum expected characters per line in file.
#define FILE_LINE_SIZE 256
// Maximum expected events in file. ARBITRARY VALUE, 
// set as needed, just avoiding malloc() and free().
#define IO_COUNTERS 64
// File name to access.
#define IO_FILENAME "/proc/self/io"
 
// The following macro follows if a string function has an error. It should 
// never happen; but it is necessary to prevent compiler warnings. We print 
// something just in case there is programmer error in invoking the function.
#define HANDLE_STRING_ERROR {fprintf(stderr,"%s:%i unexpected string function error.\n",__FILE__,__LINE__); exit(-1);}
 
typedef struct IO_native_event_entry
{
    char name[PAPI_MAX_STR_LEN];          // Name of the counter.
    char desc[PAPI_MAX_STR_LEN];       // Description of the counter.
    int fileIdx;                        // Line in file.
} IO_native_event_entry_t;
 
//-----------------------------------------------------------------------------
// Holds control flags. There's one of these per event-set. Use this to hold
// data specific to the EventSet.
//-----------------------------------------------------------------------------
typedef struct _io_control_state  
{
   int EventSetCount;
   long long EventSetVal[IO_COUNTERS];
   long long EventSetReport[IO_COUNTERS];
   int EventSetIdx[IO_COUNTERS];
} _io_control_state_t;
 
//-----------------------------------------------------------------------------
// Holds per-thread information.
//-----------------------------------------------------------------------------
typedef struct _io_context  
{
   int  EventCount;
   FILE *pFile;
   char line[FILE_LINE_SIZE]; 
} _io_context_t;
 
// ----------------------- GLOBALS ----------------------------
// We have to have a global table of events, to support event enumeration.
// We can have different file pointers for each thread, but all files must
// match the file found during _init_component().
static int gEventCount;
static IO_native_event_entry_t *io_native_table;
 
// Code to just count events in file, fills in a context.
// This may be a dummy from init_component.
static int io_count_events(_io_context_t *myCtx)
{
    myCtx->EventCount = 0;
    myCtx->pFile = fopen (IO_FILENAME,"r");
    if (myCtx->pFile == NULL) {
        int strErr=snprintf(_io_vector.cmp_info.disabled_reason, PAPI_MAX_STR_LEN,
        "Failed to open target file '%s'.", IO_FILENAME);
        _io_vector.cmp_info.disabled_reason[PAPI_MAX_STR_LEN-1]=0;
        if (strErr > PAPI_MAX_STR_LEN) HANDLE_STRING_ERROR;
        return PAPI_ENOSUPP;
    }
 
    // Just count the lines, basic vetting for ability to parse.
    while (1) {
        char *res;
        // fgets guarantees z-terminator, reads at most FILE_LINE_SIZE-1 bytes.
        res = fgets(myCtx->line, FILE_LINE_SIZE, myCtx->pFile);
        if (res  == NULL) break;
        // If the read filled the whole buffer, line is too long.
        if (strlen(myCtx->line) == (FILE_LINE_SIZE-1)) {
            fclose(myCtx->pFile);
            int strErr=snprintf(_io_vector.cmp_info.disabled_reason, PAPI_MAX_STR_LEN,
            "File '%s' line %i too long.", IO_FILENAME, myCtx->EventCount+1);
            _io_vector.cmp_info.disabled_reason[PAPI_MAX_STR_LEN-1]=0;
            if (strErr > PAPI_MAX_STR_LEN) HANDLE_STRING_ERROR;
            return PAPI_ENOSUPP;
        }
 
        char dummy[FILE_LINE_SIZE] = {0};
        long long tmplong = 0LL;
        int nf = sscanf( myCtx->line, "%s %lld\n", dummy, &tmplong);
        if (nf != 2 || strlen(dummy)<2 || dummy[strlen(dummy)-1] != ':') {
            fclose(myCtx->pFile);
            int strErr=snprintf(_io_vector.cmp_info.disabled_reason, PAPI_MAX_STR_LEN,
            "File '%s' line %i bad format.", IO_FILENAME, myCtx->EventCount+1);
            _io_vector.cmp_info.disabled_reason[PAPI_MAX_STR_LEN-1]=0;
            if (strErr > PAPI_MAX_STR_LEN) HANDLE_STRING_ERROR;
            return PAPI_ENOSUPP;
        }
 
        myCtx->EventCount++; 
    } // END READING.
 
    // NOTE: We intentionally leave file open; up to caller to close
    // or rewind and continue.
    return PAPI_OK;
} // END ROUTINE.
 
 
// Code to read values; returns PAPI_OK or an error.
// We presume the number of counters and order of them
// will not change from our initialization read.
static int 
io_hardware_read(_io_context_t *ctx, _io_control_state_t *ctl)
{
    ctx->pFile = fopen(IO_FILENAME, "r");
    if (ctx->pFile == NULL) return(PAPI_ENOCNTR); /* No counters */
 
    /* Read each line */
    int idx;
    for (idx=0; idx<gEventCount; idx++) {
        if (fgets(ctx->line, FILE_LINE_SIZE-1, ctx->pFile)) {
            char dummy[FILE_LINE_SIZE] = {0};
            long long tmplong = 0LL;
            int nf = sscanf(ctx->line, "%s %lld\n", dummy, &tmplong);
            if (nf != 2 || strlen(dummy)<2 || dummy[strlen(dummy)-1] != ':') {
                return PAPI_ENOCNTR;
            }
 
            ctl->EventSetVal[idx] = tmplong;
        } else {                            /* Did not read ALL counters. */
            return(PAPI_EMISC);
        }
    }
 
    fclose(ctx->pFile);
    return(PAPI_OK);
} // END FUNCTION.
 
/********************************************************************/
/* Below are the functions required by the PAPI component interface */
/********************************************************************/
 
static int
_io_init_component( int cidx )
{
    _io_context_t myCtx;
    int ret, fileIdx;
    SUBDBG( "_io_init_component..." );
   
    ret = io_count_events(&myCtx);
    if (ret != PAPI_OK) {
        int strErr=snprintf(_io_vector.cmp_info.disabled_reason, PAPI_MAX_STR_LEN,
        "Failed counting events.");
        _io_vector.cmp_info.disabled_reason[PAPI_MAX_STR_LEN-1]=0;    // force null termination.
        if (strErr > PAPI_MAX_STR_LEN) HANDLE_STRING_ERROR;
        goto fn_fail;
    }
 
    rewind(myCtx.pFile);
 
    if (myCtx.EventCount > IO_COUNTERS) {
        int strErr=snprintf(_io_vector.cmp_info.disabled_reason, PAPI_MAX_STR_LEN,
        "File '%s' has %i events, exceeds counter limit of %i.", IO_FILENAME, myCtx.EventCount, IO_COUNTERS);
        _io_vector.cmp_info.disabled_reason[PAPI_MAX_STR_LEN-1]=0;
        if (strErr > PAPI_MAX_STR_LEN) HANDLE_STRING_ERROR;
        fclose(myCtx.pFile);
        ret = PAPI_ENOSUPP;
        goto fn_fail;
    }
 
    // Must be same for all threads, now.
    gEventCount = myCtx.EventCount;
    /* Allocate memory for the native event table */
    io_native_table =
        ( IO_native_event_entry_t * )
        papi_calloc(gEventCount, sizeof(IO_native_event_entry_t) );
    if ( io_native_table == NULL ) {
        int strErr=snprintf(_io_vector.cmp_info.disabled_reason, PAPI_MAX_STR_LEN,
        "Failed to allocate %lu bytes for _io_native_table.", gEventCount*sizeof(IO_native_event_entry_t));
        _io_vector.cmp_info.disabled_reason[PAPI_MAX_STR_LEN-1]=0;
        if (strErr > PAPI_MAX_STR_LEN) HANDLE_STRING_ERROR;
        fclose(myCtx.pFile);
        ret = PAPI_ENOMEM;
        goto fn_fail;
    }
 
    for (fileIdx = 0; fileIdx < gEventCount; fileIdx++) {
        (void) fgets(myCtx.line, FILE_LINE_SIZE, myCtx.pFile);
        char name[FILE_LINE_SIZE] = {0};
        long long tmplong = 0LL;
        // No check for error here, we would have caught it in io_count_events().
        (void) sscanf(myCtx.line, "%s %lld\n", name, &tmplong);
        name[strlen(name)-1]=0;     // null terminate over ':' we found.
        strncpy(io_native_table[fileIdx].name, name, PAPI_MAX_STR_LEN-1);
        io_native_table[fileIdx].fileIdx=fileIdx;
        io_native_table[fileIdx].desc[0]=0;         // flag for successful copy.
        if (strcmp("rchar", name) == 0) {
            strcpy(io_native_table[fileIdx].desc, "Characters read.");
        }
        if (strcmp("wchar", name) == 0) {
            strcpy(io_native_table[fileIdx].desc, "Characters written."); 
        }
        if (strcmp("syscr", name) == 0) {
            strcpy(io_native_table[fileIdx].desc, "Characters read by system calls."); 
        }
        if (strcmp("syscw", name) == 0) {
            strcpy(io_native_table[fileIdx].desc, "Characters written by system calls."); 
        }
        if (strcmp("read_bytes", name) == 0) {
            strcpy(io_native_table[fileIdx].desc, "Binary bytes read."); 
        }
        if (strcmp("write_bytes", name) == 0) {
            strcpy(io_native_table[fileIdx].desc, "Binary bytes written."); 
        }
        if (strcmp("cancelled_write_bytes", name) == 0) {
            strcpy(io_native_table[fileIdx].desc, "Binary write bytes cancelled."); 
        }
                     
        // If none of the above found, generic description.
        if (io_native_table[fileIdx].desc[0] == 0) {    
            strcpy(io_native_table[fileIdx].desc, "No description available."); 
        }
    } // END READING.
 
    fclose(myCtx.pFile);
    // Export the total number of events available, at least on the init thread.
    _io_vector.cmp_info.num_native_events = gEventCount;
    _io_vector.cmp_info.num_cntrs = IO_COUNTERS;
    _io_vector.cmp_info.num_mpx_cntrs = IO_COUNTERS;
 
    /* Export the component id */
    _io_vector.cmp_info.CmpIdx = cidx;
  fn_exit:
    _papi_hwd[cidx]->cmp_info.disabled = ret;
    return ret;
  fn_fail:
    goto fn_exit;
} // END ROUTINE.
 
// This is called whenever a thread is initialized.
// WARNING: This can be called BEFORE init_component.
// When it is, shutdown_thread is never called, but 
// this is the default context used in calls. 
static int
_io_init_thread( hwd_context_t *ctx )
{
    _io_context_t* myCtx = (_io_context_t*) ctx;
    int ret;
    ret = io_count_events(myCtx);
    if (ret != PAPI_OK) return(ret);
 
    // File mismatch on event count kills it.
    if (gEventCount > 0 && myCtx->EventCount != gEventCount) {
        fclose(myCtx->pFile);
        myCtx->pFile = NULL;
        return PAPI_ENOSUPP;
    }
 
    fclose(myCtx->pFile);
    return PAPI_OK;
} // END of init thread.
 
// Our control state holds arrays for reading/arranging Event values.
// We just ensure it is all zeros.
static int
_io_init_control_state( hwd_control_state_t * ctl )
{
    _io_control_state_t* control = ( _io_control_state_t* ) ctl;
    memset(control, 0, sizeof(_io_control_state_t));
    return PAPI_OK;
} // END.
 
 
// Triggered by eventset operations like add or remove.
// We store the order of the events, and the number.
static int
_io_update_control_state( hwd_control_state_t *ctl, 
        NativeInfo_t *native,
        int count, 
        hwd_context_t *ctx )
{
    (void) ctx;
    _io_control_state_t *myCtl = (_io_control_state_t*) ctl;
    
    int i, index;
 
    myCtl->EventSetCount = count;
    
    /* if no events, return */
    if (count==0) return PAPI_OK;
 
    for( i = 0; i < count; i++ ) {
        index = native[i].ni_event;
        myCtl->EventSetIdx[i] = index;    
 
        /* We have no constraints on event position, so any event */
        /* can be in any slot.                                    */
        native[i].ni_position = i;
    }
 
    return PAPI_OK;
} // END ROUTINE.
 
static int
_io_start( hwd_context_t *ctx, hwd_control_state_t *ctl )
{
    (void) ctl;
    (void) ctx;
    SUBDBG( "io_start %p %p...", ctx, ctl );
    return PAPI_OK;
}
 
 
static int
_io_stop( hwd_context_t *ctx, hwd_control_state_t *ctl )
{
    (void) ctx;
    (void) ctl;
    SUBDBG( "io_stop %p %p...", ctx, ctl );
    // Don't do anything, can't stop the counters.
 
    return PAPI_OK;
}
 
 
// Triggered by PAPI_read(). We read all the events, then 
// pick out the ones the user actually requested, in their
// given order.
static int
_io_read( hwd_context_t *ctx, hwd_control_state_t *ctl,
        long long **events, int flags )
{
    // Prevent 'unused' warnings from compiler.
    (void) flags;
    _io_context_t *myCtx = (_io_context_t*) ctx;
    _io_control_state_t *myCtl = (_io_control_state_t*) ctl;
    int i;
    SUBDBG( "io_read... %p %d", ctx, flags );
 
    /* Read all counters into EventSetVal */
    io_hardware_read(myCtx, myCtl);
    for (i=0; i<myCtl->EventSetCount; i++) {
        myCtl->EventSetReport[i]=myCtl->EventSetVal[myCtl->EventSetIdx[i]];
    }
 
    /* return pointer to the values we read */
    *events = myCtl->EventSetReport; 
 
    return PAPI_OK;
}
 
/*    otherwise, the updated state is written to ESI->hw_start      */
static int
_io_write( hwd_context_t *ctx, hwd_control_state_t *ctl,
        long long *events )
{
    (void) ctx;    // unused
    (void) ctl;    // unused
    (void) events; // unused
 
    return PAPI_OK;
}
 
 
/*  If the eventset is not currently running, then the saved value in the   */
/*  EventSet is set to zero without calling this routine.                   */
/*  We don't do anything for an io reset.                                   */
static int
_io_reset( hwd_context_t *ctx, hwd_control_state_t *ctl )
{
    (void) ctx; // unused
    (void) ctl;
    SUBDBG( "io_reset...");
    return PAPI_OK;
}
 
// Triggered by PAPI_shutdown().
static int
_io_shutdown_component(void)
{
    SUBDBG( "io_shutdown_component..." );
    return PAPI_OK;
}
 
// Shutdown thread; close files. 
static int
_io_shutdown_thread( hwd_context_t *ctx )
{
    (void) ctx;
    SUBDBG( "io_shutdown_thread... %p", ctx );
    return PAPI_OK;
}
 
static int
_io_ctl( hwd_context_t *ctx, int code, _papi_int_option_t *option )
{
    (void) ctx;
    (void) code;
    (void) option;
    SUBDBG( "io_ctl..." );
    return PAPI_OK;
}
 
static int
_io_set_domain( hwd_control_state_t * cntrl, int domain )
{
    (void) cntrl;
 
    int found = 0;
    SUBDBG( "io_set_domain..." );
 
    if ( PAPI_DOM_USER & domain ) {
        SUBDBG( " PAPI_DOM_USER " );
        found = 1;
    }
    if ( PAPI_DOM_KERNEL & domain ) {
        SUBDBG( " PAPI_DOM_KERNEL " );
        found = 1;
    }
    if ( PAPI_DOM_OTHER & domain ) {
        SUBDBG( " PAPI_DOM_OTHER " );
        found = 1;
    }
    if ( PAPI_DOM_ALL & domain ) {
        SUBDBG( " PAPI_DOM_ALL " );
        found = 1;
    }
    if ( !found )
        return ( PAPI_EINVAL );
 
    return PAPI_OK;
}
 
 
/**************************************************************/
/* Naming functions, used to translate event numbers to names */
/**************************************************************/
 
 
static int
_io_ntv_enum_events( unsigned int *EventCode, int modifier )
{
    int index;
 
    switch ( modifier ) {
 
        /* return EventCode of first event */
        case PAPI_ENUM_FIRST:
            *EventCode = 0;
            return PAPI_OK;
 
        /* return EventCode of next available event */
        case PAPI_ENUM_EVENTS:
            index = *EventCode;
 
            /* Make sure we have at least 1 more event after us */
            if ( index < (gEventCount-1) ) {
                *EventCode = *EventCode + 1;
                return PAPI_OK;
            } else {
                return PAPI_ENOEVNT;
            }
            break;
 
        default:
            return PAPI_EINVAL;
    }
 
    return PAPI_EINVAL;
} // END ROUTINE
 
static int
_io_ntv_code_to_name( unsigned int EventCode, char *name, int len )
{
    int index;
    index = EventCode;
 
    /* Make sure we are in range */
    if (index >= 0 && index < gEventCount) {
        strncpy(name, io_native_table[index].name, len );  
        return PAPI_OK;
    }
 
    return PAPI_ENOEVNT;
} // END ROUTINE.
 
static int
_io_ntv_code_to_descr( unsigned int EventCode, char *descr, int len )
{
    int index;
    index = EventCode;
 
    /* make sure event is in range */
    if (index >= 0 && index < gEventCount) {
        strncpy( descr, io_native_table[index].desc, len );
        return PAPI_OK;
    }
 
    return PAPI_ENOEVNT;
}
 
papi_vector_t _io_vector = {
    .cmp_info = {
        /* default component information */
        /* (unspecified values are initialized to 0) */
        /* we explicitly set them to zero in this example */
        /* to show what settings are available            */
 
        .name = "io",
        .short_name = "io",
        .description = "A component to read /proc/self/io",
        .version = "1.0",
        .support_version = "n/a",
        .kernel_version = "n/a",
        .num_cntrs =               512,
        .num_mpx_cntrs =           512,
        .default_domain =          PAPI_DOM_USER,
        .available_domains =       PAPI_DOM_USER,
        .default_granularity =     PAPI_GRN_THR,
        .available_granularities = PAPI_GRN_THR,
        .hardware_intr_sig =       PAPI_INT_SIGNAL,
 
        /* component specific cmp_info initializations */
    },
 
    /* sizes of framework-opaque component-private structures */
    .size = {
        /* once per thread */
        .context = sizeof(_io_context_t),
        /* once per eventset */
        .control_state = sizeof(_io_control_state_t),
        .reg_value = 1, /* unused */
        .reg_alloc = 1, /* unused */
    },
 
    /* function pointers */
    /* by default they are set to NULL */
 
    /* Used for general PAPI interactions */
    .start =                _io_start,
    .stop =                 _io_stop,
    .read =                 _io_read,
    .reset =                _io_reset,    
    .write =                _io_write,
    .init_component =       _io_init_component,    
    .init_thread =          _io_init_thread,
    .init_control_state =   _io_init_control_state,
    .update_control_state = _io_update_control_state,    
    .ctl =                  _io_ctl,    
    .shutdown_thread =      _io_shutdown_thread,
    .shutdown_component =   _io_shutdown_component,
    .set_domain =           _io_set_domain,
    /* .cleanup_eventset =     NULL, */
    /* called in add_native_events() */
    /* .allocate_registers =   NULL, */
 
    /* Used for overflow/profiling */
    /* .dispatch_timer =       NULL, */
    /* .get_overflow_address = NULL, */
    /* .stop_profiling =       NULL, */
    /* .set_overflow =         NULL, */
    /* .set_profile =          NULL, */
 
    /* ??? */
    /* .user =                 NULL, */
 
    /* Name Mapping Functions */
    .ntv_enum_events =   _io_ntv_enum_events,
    .ntv_code_to_name =  _io_ntv_code_to_name,
    .ntv_code_to_descr = _io_ntv_code_to_descr,
    /* if .ntv_name_to_code not available, PAPI emulates  */
    /* it by enumerating all events and looking manually  */
    .ntv_name_to_code  = NULL,
 
 
    /* These are only used by _papi_hwi_get_native_event_info() */
    /* Which currently only uses the info for printing native   */
    /* event info, not for any sort of internal use.            */
    /* .ntv_code_to_bits =  NULL, */
 
};