X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Fwrite_tsdb.c;h=309418a185ee2261ba8fdd79331afd4e59939297;hb=23ac8e592cd64c424fddce842baea300ff8a3a85;hp=2bd27072398541c124016f1c6e97fc8c26936726;hpb=c89182b424bb4184bd7da3f2ab687b542ed7eea3;p=collectd.git diff --git a/src/write_tsdb.c b/src/write_tsdb.c index 2bd27072..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" @@ -155,9 +156,7 @@ static int wt_flush_nolock(cdtime_t timeout, struct wt_callback *cb) static int wt_callback_init(struct wt_callback *cb) { - struct addrinfo ai_hints; struct addrinfo *ai_list; - struct addrinfo *ai_ptr; int status; const char *node = cb->node ? cb->node : WT_DEFAULT_NODE; @@ -166,14 +165,11 @@ static int wt_callback_init(struct wt_callback *cb) if (cb->sock_fd > 0) return 0; - memset(&ai_hints, 0, sizeof(ai_hints)); -#ifdef AI_ADDRCONFIG - ai_hints.ai_flags |= AI_ADDRCONFIG; -#endif - ai_hints.ai_family = AF_UNSPEC; - ai_hints.ai_socktype = SOCK_STREAM; - - ai_list = NULL; + struct addrinfo ai_hints = { + .ai_family = AF_UNSPEC, + .ai_flags = AI_ADDRCONFIG, + .ai_socktype = SOCK_STREAM + }; status = getaddrinfo(node, service, &ai_hints, &ai_list); if (status != 0) @@ -184,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); @@ -506,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)) { @@ -515,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,9 +569,8 @@ static int wt_write(const data_set_t *ds, const value_list_t *vl, static int wt_config_tsd(oconfig_item_t *ci) { struct wt_callback *cb; - user_data_t user_data; + user_data_t user_data = { 0 }; char callback_name[DATA_MAX_NAME_LEN]; - int i; cb = calloc(1, sizeof(*cb)); if (cb == NULL) @@ -592,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; @@ -617,7 +611,6 @@ static int wt_config_tsd(oconfig_item_t *ci) cb->node != NULL ? cb->node : WT_DEFAULT_NODE, cb->service != NULL ? cb->service : WT_DEFAULT_SERVICE); - memset(&user_data, 0, sizeof(user_data)); user_data.data = cb; user_data.free_func = wt_callback_free; plugin_register_write(callback_name, wt_write, &user_data); @@ -630,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;