root/software/fss-parallel-tools/common/spew-throttled.h @ cec3e584
| 7e8045d8 | David Sorber | #ifndef FFSW_SPEW_THROTTLED_H
|
|
#define FFSW_SPEW_THROTTLED_H
|
|||
#include <stddef.h> // for size_t
|
|||
#include <pthread.h> // for pthread_mutex_lock, pthread_mute...
|
|||
#include "common/tick.h" // for tickns
|
|||
struct spew_throttle {
|
|||
pthread_mutex_t mx;
|
|||
const tickns_t period;
|
|||
tickns_t last_suppressed;
|
|||
size_t n_suppressed;
|
|||
};
|
|||
// To avoid the "static variable defined locally" warning
|
|||
#ifndef __CHECKER__
|
|||
#define init_throttle(__spew_throttle,wait_time) \
|
|||
static struct spew_throttle __spew_throttle = { \
|
|||
.mx = PTHREAD_MUTEX_INITIALIZER, \
|
|||
.period = (wait_time), \
|
|||
.last_suppressed = 0, \
|
|||
.n_suppressed = 0, \
|
|||
};
|
|||
#else
|
|||
#define init_throttle(obj,wait_time) \
|
|||
struct spew_throttle obj = { \
|
|||
.mx = PTHREAD_MUTEX_INITIALIZER, \
|
|||
.period = (wait_time), \
|
|||
.last_suppressed = 0, \
|
|||
.n_suppressed = 0, \
|
|||
};
|
|||
#endif // __CHECKER__
|
|||
#define spew_throttled(wait_time, level, format, ...) \
|
|||
({ \
|
|||
init_throttle(__spew_throttle, wait_time); \
|
|||
CHECK0(pthread_mutex_lock(&__spew_throttle.mx)); \
|
|||
tickns_t __now = tickns(); \
|
|||
if (__now >= (__spew_throttle.last_suppressed) + ( __spew_throttle.period)) { \
|
|||
__spew_throttle.last_suppressed = __now; \
|
|||
spew(level,format " (suppressed:%zu)", ##__VA_ARGS__, __spew_throttle.n_suppressed); \
|
|||
__spew_throttle.n_suppressed = 0; \
|
|||
} \
|
|||
else { \
|
|||
__spew_throttle.n_suppressed += 1; \
|
|||
} \
|
|||
CHECK0(pthread_mutex_unlock(&__spew_throttle.mx)); \
|
|||
})
|
|||
#endif // FFSW_SPEW_THROTTLED_H
|