X-Git-Url: https://git.octo.it/?p=collectd.git;a=blobdiff_plain;f=src%2Futils_latency.h;h=9d878dabcda3ff0d7287f8a3dc332c73b2e3171e;hp=cb56b082524c87c33f34cf7836b01851bd8176f6;hb=da11ce02eb202b3e01d3e2d1b40f248a84430973;hpb=f0d468892e1c173b226f739be48291981473b4fb diff --git a/src/utils_latency.h b/src/utils_latency.h index cb56b082..9d878dab 100644 --- a/src/utils_latency.h +++ b/src/utils_latency.h @@ -28,21 +28,36 @@ #include "utils_time.h" +#ifndef HISTOGRAM_NUM_BINS +#define HISTOGRAM_NUM_BINS 1000 +#endif + struct latency_counter_s; typedef struct latency_counter_s latency_counter_t; -latency_counter_t *latency_counter_create (void); -void latency_counter_destroy (latency_counter_t *lc); +latency_counter_t *latency_counter_create(void); +void latency_counter_destroy(latency_counter_t *lc); -void latency_counter_add (latency_counter_t *lc, cdtime_t latency); -void latency_counter_reset (latency_counter_t *lc); +void latency_counter_add(latency_counter_t *lc, cdtime_t latency); +void latency_counter_reset(latency_counter_t *lc); -cdtime_t latency_counter_get_min (latency_counter_t *lc); -cdtime_t latency_counter_get_max (latency_counter_t *lc); -cdtime_t latency_counter_get_sum (latency_counter_t *lc); -size_t latency_counter_get_num (latency_counter_t *lc); -cdtime_t latency_counter_get_average (latency_counter_t *lc); -cdtime_t latency_counter_get_percentile (latency_counter_t *lc, - double percent); +cdtime_t latency_counter_get_min(latency_counter_t *lc); +cdtime_t latency_counter_get_max(latency_counter_t *lc); +cdtime_t latency_counter_get_sum(latency_counter_t *lc); +size_t latency_counter_get_num(latency_counter_t *lc); +cdtime_t latency_counter_get_average(latency_counter_t *lc); +cdtime_t latency_counter_get_percentile(latency_counter_t *lc, double percent); -/* vim: set sw=2 sts=2 et : */ +/* + * NAME + * latency_counter_get_rate(counter,lower,upper,now) + * + * DESCRIPTION + * Calculates rate of latency values fall within requested interval. + * Interval specified as (lower,upper], i.e. the lower boundary is exclusive, + * the upper boundary is inclusive. + * When lower is zero, then the interval is (0, upper]. + * When upper is zero, then the interval is (lower, infinity). + */ +double latency_counter_get_rate(const latency_counter_t *lc, cdtime_t lower, + cdtime_t upper, const cdtime_t now);