X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Fwrite_tsdb.c;h=309418a185ee2261ba8fdd79331afd4e59939297;hb=d1bc5fb594a846ce31e4326bc81520a58b6310f8;hp=fe418cf9e7d616f402b6defaad8d3bcd8482ea04;hpb=aa3811995bfae69f0d1a0f897acfa4a9a4c0138a;p=collectd.git diff --git a/src/write_tsdb.c b/src/write_tsdb.c index fe418cf9..309418a1 100644 --- a/src/write_tsdb.c +++ b/src/write_tsdb.c @@ -42,6 +42,7 @@ */ #include "collectd.h" + #include "common.h" #include "plugin.h" #include "configfile.h" @@ -156,7 +157,6 @@ static int wt_flush_nolock(cdtime_t timeout, struct wt_callback *cb) static int wt_callback_init(struct wt_callback *cb) { struct addrinfo *ai_list; - struct addrinfo *ai_ptr; int status; const char *node = cb->node ? cb->node : WT_DEFAULT_NODE; @@ -165,8 +165,6 @@ static int wt_callback_init(struct wt_callback *cb) if (cb->sock_fd > 0) return 0; - ai_list = NULL; - struct addrinfo ai_hints = { .ai_family = AF_UNSPEC, .ai_flags = AI_ADDRCONFIG, @@ -182,7 +180,7 @@ static int wt_callback_init(struct wt_callback *cb) } assert (ai_list != NULL); - for (ai_ptr = ai_list; ai_ptr != NULL; ai_ptr = ai_ptr->ai_next) + for (struct addrinfo *ai_ptr = ai_list; ai_ptr != NULL; ai_ptr = ai_ptr->ai_next) { cb->sock_fd = socket(ai_ptr->ai_family, ai_ptr->ai_socktype, ai_ptr->ai_protocol); @@ -504,7 +502,6 @@ static int wt_write_messages(const data_set_t *ds, const value_list_t *vl, char values[512]; int status; - size_t i; if (0 != strcmp(ds->type, vl->type)) { @@ -513,7 +510,7 @@ static int wt_write_messages(const data_set_t *ds, const value_list_t *vl, return -1; } - for (i = 0; i < ds->ds_num; i++) + for (size_t i = 0; i < ds->ds_num; i++) { const char *ds_name = NULL; @@ -574,7 +571,6 @@ static int wt_config_tsd(oconfig_item_t *ci) struct wt_callback *cb; user_data_t user_data = { 0 }; char callback_name[DATA_MAX_NAME_LEN]; - int i; cb = calloc(1, sizeof(*cb)); if (cb == NULL) @@ -590,7 +586,7 @@ static int wt_config_tsd(oconfig_item_t *ci) pthread_mutex_init (&cb->send_lock, NULL); - for (i = 0; i < ci->children_num; i++) + for (int i = 0; i < ci->children_num; i++) { oconfig_item_t *child = ci->children + i; @@ -627,9 +623,7 @@ static int wt_config_tsd(oconfig_item_t *ci) static int wt_config(oconfig_item_t *ci) { - int i; - - for (i = 0; i < ci->children_num; i++) + for (int i = 0; i < ci->children_num; i++) { oconfig_item_t *child = ci->children + i;