linux-mx.c File Reference

A component for Myricom MX (Myrinet Express) More...

Include dependency graph for linux-mx.c:

Go to the source code of this file.

Data Structures
struct	MX_register_t
struct	MX_native_event_entry_t
struct	MX_reg_alloc_t
struct	MX_control_state_t
struct	MX_context_t

Macros
#define	MX_MAX_COUNTERS   100
#define	MX_MAX_COUNTER_TERMS   MX_MAX_COUNTERS
#define	LINELEN   128

Functions
static int	read_mx_counters (long long *counters)
static int	_mx_init_component (int cidx)
static int	_mx_init_thread (hwd_context_t *ctx)
static int	_mx_shutdown_component (void)
static int	_mx_shutdown_thread (hwd_context_t *ctx)
static int	_mx_init_control_state (hwd_control_state_t *ctl)
static int	_mx_update_control_state (hwd_control_state_t *ctl, NativeInfo_t *native, int count, hwd_context_t *ctx)
static int	_mx_start (hwd_context_t *ctx, hwd_control_state_t *ctl)
static int	_mx_stop (hwd_context_t *ctx, hwd_control_state_t *ctl)
static int	_mx_read (hwd_context_t *ctx, hwd_control_state_t *ctl, long long **events, int flags)
static int	_mx_reset (hwd_context_t *ctx, hwd_control_state_t *ctrl)
static int	_mx_ctl (hwd_context_t *ctx, int code, _papi_int_option_t *option)
static int	_mx_set_domain (hwd_control_state_t *cntrl, int domain)
static int	_mx_ntv_code_to_name (unsigned int EventCode, char *name, int len)
static int	_mx_ntv_code_to_descr (unsigned int EventCode, char *name, int len)
static int	_mx_ntv_enum_events (unsigned int *EventCode, int modifier)

Variables
static const MX_native_event_entry_t	mx_native_table []
static int	num_events =0
papi_vector_t	_mx_vector
static char	mx_counters_exe [BUFSIZ]

Macro Definition Documentation

LINELEN

#define LINELEN   128

Definition at line 20 of file linux-mx.c.

MX_MAX_COUNTER_TERMS

#define MX_MAX_COUNTER_TERMS   MX_MAX_COUNTERS

Definition at line 18 of file linux-mx.c.

MX_MAX_COUNTERS

#define MX_MAX_COUNTERS   100

Definition at line 17 of file linux-mx.c.

Function Documentation

_mx_ctl()

static int _mx_ctl ( hwd_context_t *  ctx, int  code, _papi_int_option_t *  option  )

static

Definition at line 447 of file linux-mx.c.

{
    ( void ) ctx;            /*unused */
    ( void ) code;           /*unused */
    ( void ) option;         /*unused */
 
    return PAPI_OK;
}

_mx_init_component()

static int _mx_init_component ( int  cidx )

static

Definition at line 223 of file linux-mx.c.

{
    int retval = PAPI_OK;
    FILE *fff;
    char *path;
    int checklen, len, pathlen;
 
    /* detect if MX available */
 
    path = getenv("PATH");
    pathlen = strlen(path);
    while(pathlen > 0) {
       len = strcspn(path, ":");
       if (len < BUFSIZ) {
          strncpy(mx_counters_exe, path, len);
       } else {
          fff = NULL;
          break;
       }
       mx_counters_exe[len] = '\0';
       checklen = len + strlen("/mx_counters");
       if (checklen < BUFSIZ) {
          strcat(mx_counters_exe, "/mx_counters");
       } else {
          fff = NULL;
          break;
       }
       fff = fopen(mx_counters_exe, "r");
       if (fff != NULL) {
          checklen = checklen + strlen(" 2> /dev/null");
          if (checklen < BUFSIZ) {
             strcat(mx_counters_exe, " 2> /dev/null");
             break;
          } else {
             fclose(fff);
             fff = NULL;
             break;
          }
       }
       pathlen = pathlen - len - 1;
       if (pathlen > 0) {
          path = path + len + 1;
       }
    }
    if (fff == NULL) {
       /* mx_counters not found */
       strncpy(_mx_vector.cmp_info.disabled_reason,
           "No MX utilities found",PAPI_MAX_STR_LEN);
       retval = PAPI_ECMP;
       goto fn_fail;
    }
    fclose(fff);
 
    num_events=MX_MAX_COUNTERS;
    _mx_vector.cmp_info.num_native_events=num_events;
 
    /* Export the component id */
    _mx_vector.cmp_info.CmpIdx = cidx;
 
  fn_exit:
    _papi_hwd[cidx]->cmp_info.disabled = retval;
    return retval;
  fn_fail:
    goto fn_exit;
}

Here is the call graph for this function:

_mx_init_control_state()

static int _mx_init_control_state ( hwd_control_state_t *  ctl )

static

Definition at line 321 of file linux-mx.c.

{
    ( void ) ctl;            /*unused */
 
    return PAPI_OK;
}

_mx_init_thread()

static int _mx_init_thread ( hwd_context_t *  ctx )

static

Definition at line 294 of file linux-mx.c.

{
    ( void ) ctx;            /*unused */
    return PAPI_OK;
}

_mx_ntv_code_to_descr()

static int _mx_ntv_code_to_descr ( unsigned int  EventCode, char *  name, int  len  )

static

Definition at line 495 of file linux-mx.c.

{
    int event=EventCode;
 
    if (event >=0 && event < num_events) {
       strncpy( name, mx_native_table[event].description, len );
       return PAPI_OK;
    }
    return PAPI_ENOEVNT;
}

_mx_ntv_code_to_name()

static int _mx_ntv_code_to_name ( unsigned int  EventCode, char *  name, int  len  )

static

Definition at line 480 of file linux-mx.c.

{
 
    int event=EventCode;
 
    if (event >=0 && event < num_events) {
      strncpy( name, mx_native_table[event].name, len );
      return PAPI_OK;
    }
    return PAPI_ENOEVNT;
 
 
}

_mx_ntv_enum_events()

static int _mx_ntv_enum_events ( unsigned int *  EventCode, int  modifier  )

static

Definition at line 509 of file linux-mx.c.

{
 
    if ( modifier == PAPI_ENUM_FIRST ) {
       if (num_events==0) return PAPI_ENOEVNT;
       *EventCode = 0;
       return PAPI_OK;
    }
 
    if ( modifier == PAPI_ENUM_EVENTS ) {
        int index = *EventCode;
 
        if ( mx_native_table[index + 1].resources.selector ) {
            *EventCode = *EventCode + 1;
            return PAPI_OK;
        } else {
            return PAPI_ENOEVNT;
        }
    }
        
        return PAPI_EINVAL;
}

_mx_read()

static int _mx_read ( hwd_context_t *  ctx, hwd_control_state_t *  ctl, long long **  events, int  flags  )

static

Definition at line 396 of file linux-mx.c.

{
    ( void ) ctx;            /*unused */
    ( void ) flags;          /*unused */
    int i;
        long long mx_counters[MX_MAX_COUNTERS];
 
    MX_control_state_t *mx_ctl = (MX_control_state_t *)ctl;
 
    read_mx_counters( mx_counters );
 
    for ( i = 0; i < mx_ctl->num_events; i++ ) {
            mx_ctl->current_count[i]=
             mx_counters[mx_ctl->which_counter[i]];
        mx_ctl->difference[i] = mx_ctl->current_count[i]-
                                   mx_ctl->start_count[i];
    }
    *events = mx_ctl->difference;
 
    return PAPI_OK;
}

Here is the call graph for this function:

_mx_reset()

static int _mx_reset ( hwd_context_t *  ctx, hwd_control_state_t *  ctrl  )

static

Definition at line 421 of file linux-mx.c.

{
    _mx_start( ctx, ctrl );
    return PAPI_OK;
}

Here is the call graph for this function:

_mx_set_domain()

static int _mx_set_domain ( hwd_control_state_t *  cntrl, int  domain  )

static

Definition at line 467 of file linux-mx.c.

{
    ( void ) cntrl;          /*unused */
    if ( PAPI_DOM_ALL != domain ) {
        return PAPI_EINVAL;
    }
 
    return PAPI_OK;
}

_mx_shutdown_component()

static int _mx_shutdown_component ( void  )

static

Definition at line 302 of file linux-mx.c.

{
  return PAPI_OK;
}

_mx_shutdown_thread()

static int _mx_shutdown_thread ( hwd_context_t *  ctx )

static

Definition at line 308 of file linux-mx.c.

{
    ( void ) ctx;            /*unused */
    return PAPI_OK;
}

_mx_start()

static int _mx_start ( hwd_context_t *  ctx, hwd_control_state_t *  ctl  )

static

Definition at line 352 of file linux-mx.c.

{
 
        long long mx_counters[MX_MAX_COUNTERS];
 
    ( void ) ctx;            /*unused */
 
    MX_control_state_t *mx_ctl = (MX_control_state_t *)ctl;
    int i;
 
    read_mx_counters( mx_counters );
 
    //  for(i=0;i<MX_MAX_COUNTERS;i++) printf("%d %lld\n",i,mx_counters[i]);
 
    for(i=0;i<mx_ctl->num_events;i++) {
           mx_ctl->current_count[i]=
             mx_counters[mx_ctl->which_counter[i]];
       mx_ctl->start_count[i]=mx_ctl->current_count[i];
    }
 
    return PAPI_OK;
}

Here is the call graph for this function:

Here is the caller graph for this function:

_mx_stop()

static int _mx_stop ( hwd_context_t *  ctx, hwd_control_state_t *  ctl  )

static

Definition at line 377 of file linux-mx.c.

{
    ( void ) ctx;            /*unused */
 
        long long mx_counters[MX_MAX_COUNTERS];
    MX_control_state_t *mx_ctl = (MX_control_state_t *)ctl;
    int i;
 
    read_mx_counters( mx_counters );
 
    for(i=0;i<mx_ctl->num_events;i++) {
           mx_ctl->current_count[i]=
             mx_counters[mx_ctl->which_counter[i]];
    }
 
    return PAPI_OK;
}

Here is the call graph for this function:

_mx_update_control_state()

static int _mx_update_control_state ( hwd_control_state_t *  ctl, NativeInfo_t *  native, int  count, hwd_context_t *  ctx  )

static

Definition at line 329 of file linux-mx.c.

{
    ( void ) ctx;            /*unused */
    int i, index;
    
    MX_control_state_t *mx_ctl = (MX_control_state_t *)ctl;
 
    for(i=0; i<count; i++ ) {
        index = native[i].ni_event;
        mx_ctl->which_counter[i]=index;
        //      printf("Mapping event# %d to HW counter %d (count=%d)\n",
        //     i,index,count); 
        native[i].ni_position = i;
    }
 
    mx_ctl->num_events=count;
 
    return PAPI_OK;
}

read_mx_counters()

static int read_mx_counters ( long long *  counters )

static

Definition at line 167 of file linux-mx.c.

{
    FILE *fp;
    char line[LINELEN];
    int i, linenum;
 
    /* Open a pipe to the mx_counters executable */
 
    fp = popen( mx_counters_exe, "r" );
    if ( !fp ) {
       perror( "popen" );
       return PAPI_ECMP;
    }
 
 
    /* A line of output looks something similar to:       */
        /* "    Lanai uptime (seconds):     766268 (0xbb13c)" */
 
    /* This code may fail if number of ports on card > 1 */
 
    linenum = 0;
    while ( fgets( line, LINELEN, fp ) ) {
      //       printf("%s",line);
       for(i=0; line[i]!= '\0' && i<LINELEN-1;i++) {
 
          /* skip to colon */
          if (line[i]==':') {
 
             /* read in value */
             if (line[i+1]!='\0') {
           //       printf("Line %d trying %s",linenum,&line[i+1]);
                sscanf(&line[i+1],"%lld",&counters[linenum]);
            linenum++;
            break;
         }
          }
       }
       if (linenum>=MX_MAX_COUNTERS) break;
    }
 
    pclose( fp );
 
    return PAPI_OK;
}

Here is the caller graph for this function:

Variable Documentation

_mx_vector

papi_vector_t _mx_vector

Definition at line 162 of file linux-mx.c.

mx_counters_exe

char mx_counters_exe[BUFSIZ]

static

Definition at line 164 of file linux-mx.c.

mx_native_table

const MX_native_event_entry_t mx_native_table[]

static

Definition at line 58 of file linux-mx.c.

num_events

int num_events =0

static

Definition at line 161 of file linux-mx.c.