X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Faggregation.c;h=bb37b858fd846737bd48c204434b5257287d2f48;hb=7747e2ad9a86c2307094cd4ca3f753e46329c7a5;hp=3d5f396aa53ad453db5e320b12a0b9f9c9e56d63;hpb=ff9e11ade5cfabf32c63fb19fc76cbbc4186bc5b;p=collectd.git diff --git a/src/aggregation.c b/src/aggregation.c index 3d5f396a..bb37b858 100644 --- a/src/aggregation.c +++ b/src/aggregation.c @@ -26,11 +26,8 @@ #include "collectd.h" -#include - #include "plugin.h" #include "common.h" -#include "configfile.h" #include "meta_data.h" #include "utils_cache.h" /* for uc_get_rate() */ #include "utils_subst.h" @@ -41,7 +38,7 @@ struct aggregation_s /* {{{ */ { - identifier_t ident; + lookup_identifier_t ident; unsigned int group_by; unsigned int regex_fields; @@ -65,7 +62,7 @@ typedef struct agg_instance_s agg_instance_t; struct agg_instance_s /* {{{ */ { pthread_mutex_t lock; - identifier_t ident; + lookup_identifier_t ident; int ds_type; @@ -348,7 +345,6 @@ static int agg_instance_read_func (agg_instance_t *inst, /* {{{ */ else sstrncpy (vl->plugin_instance, func, sizeof (vl->plugin_instance)); - memset (&v, 0, sizeof (v)); status = rate_to_value (&v, rate, state, inst->ds_type, t); if (status != 0) { @@ -486,9 +482,7 @@ static void agg_lookup_free_obj_callback (void *user_obj) /* {{{ */ static int agg_config_handle_group_by (oconfig_item_t const *ci, /* {{{ */ aggregation_t *agg) { - int i; - - for (i = 0; i < ci->values_num; i++) + for (int i = 0; i < ci->values_num; i++) { char const *value; @@ -524,7 +518,6 @@ static int agg_config_aggregation (oconfig_item_t *ci) /* {{{ */ aggregation_t *agg; _Bool is_valid; int status; - int i; agg = calloc (1, sizeof (*agg)); if (agg == NULL) @@ -541,7 +534,7 @@ static int agg_config_aggregation (oconfig_item_t *ci) /* {{{ */ sstrncpy (agg->ident.type_instance, "/.*/", sizeof (agg->ident.type_instance)); - for (i = 0; i < ci->children_num; i++) + for (int i = 0; i < ci->children_num; i++) { oconfig_item_t *child = ci->children + i; @@ -679,8 +672,6 @@ static int agg_config_aggregation (oconfig_item_t *ci) /* {{{ */ static int agg_config (oconfig_item_t *ci) /* {{{ */ { - int i; - pthread_mutex_lock (&agg_instance_list_lock); if (lookup == NULL) @@ -697,7 +688,7 @@ static int agg_config (oconfig_item_t *ci) /* {{{ */ } } - for (i = 0; i < ci->children_num; i++) + for (int i = 0; i < ci->children_num; i++) { oconfig_item_t *child = ci->children + i; @@ -715,7 +706,6 @@ static int agg_config (oconfig_item_t *ci) /* {{{ */ static int agg_read (void) /* {{{ */ { - agg_instance_t *this; cdtime_t t; int success; @@ -736,7 +726,7 @@ static int agg_read (void) /* {{{ */ return (0); } - for (this = agg_instance_list_head; this != NULL; this = this->next) + for (agg_instance_t *this = agg_instance_list_head; this != NULL; this = this->next) { int status;