From 0abbabbe10040f562c49dcefd27c502356c5ef44 Mon Sep 17 00:00:00 2001 From: Unbit Date: Wed, 13 Nov 2013 19:51:22 +0100 Subject: [PATCH] added accumulator metrics collector --- core/metrics.c | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/core/metrics.c b/core/metrics.c index 47dc8ee0..b9e7d269 100644 --- a/core/metrics.c +++ b/core/metrics.c @@ -970,6 +970,18 @@ static int64_t uwsgi_metric_collector_sum(struct uwsgi_metric *um) { return total; } +static int64_t uwsgi_metric_collector_accumulator(struct uwsgi_metric *um) { + int64_t total = *um->value; + struct uwsgi_metric_child *umc = um->children; + while(umc) { + struct uwsgi_metric *c = umc->um; + total += *c->value; + umc = umc->next; + } + + return total; +} + static int64_t uwsgi_metric_collector_avg(struct uwsgi_metric *um) { int64_t total = 0; int64_t count = 0; @@ -1001,6 +1013,7 @@ void uwsgi_metrics_collectors_setup() { uwsgi_register_metric_collector("ptr", uwsgi_metric_collector_ptr); uwsgi_register_metric_collector("file", uwsgi_metric_collector_file); uwsgi_register_metric_collector("sum", uwsgi_metric_collector_sum); + uwsgi_register_metric_collector("accumulator", uwsgi_metric_collector_accumulator); uwsgi_register_metric_collector("avg", uwsgi_metric_collector_avg); uwsgi_register_metric_collector("func", uwsgi_metric_collector_func); }