sde_internal.h File Reference

Include dependency graph for sde_internal.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures
struct	sde_register_t
struct	sde_reg_alloc_t
struct	sde_control_state_t
struct	sde_context_t

Macros
#define	SDE_MAX_SIMULTANEOUS_COUNTERS   40
#define	REGISTERED_EVENT_MASK   0x2;

Functions
static int	_sde_reset (hwd_context_t *ctx, hwd_control_state_t *ctl)
static int	_sde_write (hwd_context_t *ctx, hwd_control_state_t *ctl, long long *events)
static int	_sde_read (hwd_context_t *ctx, hwd_control_state_t *ctl, long long **events, int flags)
static int	_sde_stop (hwd_context_t *ctx, hwd_control_state_t *ctl)
static int	_sde_start (hwd_context_t *ctx, hwd_control_state_t *ctl)
static int	_sde_update_control_state (hwd_control_state_t *ctl, NativeInfo_t *native, int count, hwd_context_t *ctx)
static int	_sde_init_control_state (hwd_control_state_t *ctl)
static int	_sde_init_thread (hwd_context_t *ctx)
static int	_sde_init_component (int cidx)
static int	_sde_shutdown_component (void)
static int	_sde_shutdown_thread (hwd_context_t *ctx)
static int	_sde_ctl (hwd_context_t *ctx, int code, _papi_int_option_t *option)
static int	_sde_set_domain (hwd_control_state_t *cntrl, int domain)
static int	_sde_ntv_enum_events (unsigned int *EventCode, int modifier)
static int	_sde_ntv_code_to_name (unsigned int EventCode, char *name, int len)
static int	_sde_ntv_code_to_descr (unsigned int EventCode, char *descr, int len)
static int	_sde_ntv_name_to_code (const char *name, unsigned int *event_code)
static void	_sde_dispatch_timer (int n, hwd_siginfo_t *info, void *uc)
static void	invoke_user_handler (unsigned int cntr_uniq_id)
static int	do_set_timer_for_overflow (sde_control_state_t *sde_ctl)
static int	sde_arm_timer (sde_control_state_t *sde_ctl)
int	papi_sde_lock (void)
int	papi_sde_unlock (void)
void	papi_sde_check_overflow_status (unsigned int cntr_uniq_id, long long int latest)
int	papi_sde_set_timer_for_overflow (void)
	__attribute__ ((__common__)) int(*sde_ti_reset_counter_ptr)(uint32_t)

Variables
long long int long	long
	int

Macro Definition Documentation

REGISTERED_EVENT_MASK

#define REGISTERED_EVENT_MASK   0x2;

Definition at line 19 of file sde_internal.h.

SDE_MAX_SIMULTANEOUS_COUNTERS

#define SDE_MAX_SIMULTANEOUS_COUNTERS   40

Definition at line 5 of file sde_internal.h.

Function Documentation

__attribute__()

__attribute__

(

(__common__)

)

_sde_ctl()

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

static

_sde_dispatch_timer()

static void _sde_dispatch_timer ( int  n, hwd_siginfo_t *  info, void *  uc  )

static

Definition at line 721 of file sde.c.

                                                                {
 
    _papi_hwi_context_t hw_context;
    vptr_t address;
    ThreadInfo_t *thread;
    int i, cidx, retval, isHardware, slow_down, speed_up;
    int found_registered_counters, period_has_changed = 0;
    EventSetInfo_t *ESI;
    struct itimerspec its;
    long long overflow_vector = 0;
    sde_control_state_t *sde_ctl;
 
    (void) n;
 
    SUBDBG("SDE timer expired. Dispatching (papi internal) overflow handler\n");
 
    thread = _papi_hwi_lookup_thread( 0 );
    cidx = _sde_vector.cmp_info.CmpIdx;
 
    ESI = thread->running_eventset[cidx];
    // This holds only the number of events in the eventset that are set to overflow.
    int event_counter = ESI->overflow.event_counter;
    sde_ctl = ( sde_control_state_t * ) ESI->ctl_state;
 
    retval = _papi_hwi_read( thread->context[cidx], ESI, ESI->sw_stop );
    if ( retval < PAPI_OK )
        return;
 
    slow_down = 0;
    speed_up = 0;
    found_registered_counters = 0;
    // Reset the deadline of counters which have exceeded the current deadline
    // and check if we need to slow down the frequency of the timer.
    for ( i = 0; i < event_counter; i++ ) {
        int papi_index = ESI->overflow.EventIndex[i];
        long long deadline, threshold, latest, previous, diff;
 
        uint32_t counter_uniq_id = sde_ctl->which_counter[papi_index];
        if( !sde_ti_is_simple_counter_ptr( counter_uniq_id ) )
            continue;
 
        found_registered_counters = 1;
 
        latest = ESI->sw_stop[papi_index];
        deadline = ESI->overflow.deadline[i];
        threshold = ESI->overflow.threshold[i];
 
        // Find the increment from the previous measurement.
        previous = sde_ctl->previous_value[papi_index];
 
        // NOTE: The following code assumes that the counters are "long long". No other
        // NOTE: type will work correctly.
        diff = latest-previous;
 
        // If it's too small we need to slow down the timer, it it's
        // too large we need to speed up the timer.
        if( 30*diff < threshold ){
            slow_down = 1; // I.e., grow the sampling period
        }else if( 10*diff > threshold ){
            speed_up = 1; // I.e., shrink the sampling period
        }
 
        // Update the "previous" measurement to be the latest one.
        sde_ctl->previous_value[papi_index] = latest;
 
        // If this counter has exceeded the deadline, add it in the vector.
        if ( latest >= deadline ) {
            // pos[0] holds the first among the native events that compose the given event. If it is a derived event,
            // then it might be made up of multiple native events, but this is a CPU component concept. The SDE component
            // does not have derived events (the groups are first class citizens, they don't have multiple pos[] entries).
            int pos = ESI->EventInfoArray[papi_index].pos[0];
            SUBDBG ( "Event at index %d (and pos %d) has value %lld which exceeds deadline %lld (threshold %lld, accuracy %.2lf)\n",
                     papi_index, pos, latest, deadline, threshold, 100.0*(double)(latest-deadline)/(double)threshold);
 
            overflow_vector ^= ( long long ) 1 << pos;
            // We adjust the deadline in a way that it remains a multiple of threshold so we don't create an additive error.
            ESI->overflow.deadline[i] = threshold*(latest/threshold) + threshold;
        }
    }
 
    if( !found_registered_counters && sde_ctl->has_timer ){
        struct itimerspec zero_time;
        memset(&zero_time, 0, sizeof(struct itimerspec));
        if (timer_settime(sde_ctl->timerid, 0, &zero_time, NULL) == -1){
            PAPIERROR("timer_settime");
            timer_delete(sde_ctl->timerid);
            sde_ctl->has_timer = 0;
            return;
        }
        goto no_change_in_period;
    }
 
    // Since we potentially check multiple counters in the loop above, both conditions could be true (for different counter).
    // In this case, we give speed_up priority.
    if( speed_up )
        slow_down = 0;
 
    // If neither was set, there is nothing to do here.
    if( !speed_up && !slow_down )
        goto no_change_in_period;
 
    if( !sde_ctl->has_timer )
        goto no_change_in_period;
 
    // Get the current value of the timer.
    if( timer_gettime(sde_ctl->timerid, &its) == -1){
        PAPIERROR("timer_gettime() failed. Timer will not be modified.\n");
        goto no_change_in_period;
    }
 
    period_has_changed = 0;
    // We only reduce the period if it is above 131.6us, so it never drops below 100us.
    if( speed_up && (its.it_interval.tv_nsec > 131607) ){
        double new_val = (double)its.it_interval.tv_nsec;
        new_val /= 1.31607; // sqrt(sqrt(3)) = 1.316074
        its.it_value.tv_nsec = (int)new_val;
        its.it_interval.tv_nsec = its.it_value.tv_nsec;
        period_has_changed = 1;
        SUBDBG ("Timer will be sped up to %ld ns\n", its.it_value.tv_nsec);
    }
 
    // We only increase the period if it is below 75.9ms, so it never grows above 100ms.
    if( slow_down && (its.it_interval.tv_nsec < 75983800) ){
        double new_val = (double)its.it_interval.tv_nsec;
        new_val *= 1.31607; // sqrt(sqrt(3)) = 1.316074
        its.it_value.tv_nsec = (int)new_val;
        its.it_interval.tv_nsec = its.it_value.tv_nsec;
        period_has_changed = 1;
        SUBDBG ("Timer will be slowed down to %ld ns\n", its.it_value.tv_nsec);
    }
 
    if( !period_has_changed )
        goto no_change_in_period;
 
    if (timer_settime(sde_ctl->timerid, 0, &its, NULL) == -1){
        PAPIERROR("timer_settime() failed when modifying PAPI internal timer. This might have broken overflow support for this eventset.\n");
        goto no_change_in_period;
    }
 
no_change_in_period:
 
    // If none of the events exceeded their deadline, there is nothing else to do.
    if( 0 == overflow_vector ){
        return;
    }
 
    if ( (NULL== thread) || (NULL == thread->running_eventset[cidx]) || (0 == thread->running_eventset[cidx]->overflow.flags) ){
        PAPIERROR( "_sde_dispatch_timer(): 'Can not access overflow flags'");
        return;
    }
 
    hw_context.si = info;
    hw_context.ucontext = ( hwd_ucontext_t * ) uc;
 
    address = GET_OVERFLOW_ADDRESS( hw_context );
 
    int genOverflowBit = 0;
 
    _papi_hwi_dispatch_overflow_signal( ( void * ) &hw_context, address, &isHardware, overflow_vector, genOverflowBit, &thread, cidx );
 
   return;
}

Here is the call graph for this function:

Here is the caller graph for this function:

_sde_init_component()

static int _sde_init_component ( int  cidx )

static

_sde_init_control_state()

static int _sde_init_control_state ( hwd_control_state_t *  ctl )

static

_sde_init_thread()

static int _sde_init_thread ( hwd_context_t *  ctx )

static

_sde_ntv_code_to_descr()

static int _sde_ntv_code_to_descr ( unsigned int  EventCode, char *  descr, int  len  )

static

_sde_ntv_code_to_name()

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

static

_sde_ntv_enum_events()

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

static

_sde_ntv_name_to_code()

static int _sde_ntv_name_to_code ( const char *  name, unsigned int *  event_code  )

static

_sde_read()

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

static

_sde_reset()

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

static

_sde_set_domain()

static int _sde_set_domain ( hwd_control_state_t *  cntrl, int  domain  )

static

_sde_shutdown_component()

static int _sde_shutdown_component ( void  )

static

_sde_shutdown_thread()

static int _sde_shutdown_thread ( hwd_context_t *  ctx )

static

_sde_start()

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

static

_sde_stop()

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

static

_sde_update_control_state()

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

static

_sde_write()

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

static

do_set_timer_for_overflow()

static int do_set_timer_for_overflow ( sde_control_state_t *  sde_ctl )

static

invoke_user_handler()

static void invoke_user_handler ( unsigned int  cntr_uniq_id )

static

papi_sde_check_overflow_status()

void papi_sde_check_overflow_status	(	unsigned int	cntr_uniq_id,
		long long int	latest
	)

Here is the caller graph for this function:

papi_sde_lock()

int papi_sde_lock

(

void

)

papi_sde_set_timer_for_overflow()

int papi_sde_set_timer_for_overflow

(

void

)

Here is the caller graph for this function:

papi_sde_unlock()

int papi_sde_unlock

(

void

)

sde_arm_timer()

static int sde_arm_timer ( sde_control_state_t *  sde_ctl )

inlinestatic

Variable Documentation

int

int

Definition at line 89 of file sde_internal.h.

long

long long int long long

Definition at line 85 of file sde_internal.h.