X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Fwrite_redis.c;h=bafbfe511930fc30e70ff513019e9cb0c4dc8f95;hb=8c5927c52f4eefebaad3a6ecadc253ee9007ebb5;hp=5c299a489dfa6eef0f914992f595df1cf55c48ce;hpb=cd5602386cf810ade2750bf026e5fe340765ce05;p=collectd.git diff --git a/src/write_redis.c b/src/write_redis.c index 5c299a48..bafbfe51 100644 --- a/src/write_redis.c +++ b/src/write_redis.c @@ -25,9 +25,9 @@ **/ #include "collectd.h" + #include "plugin.h" #include "common.h" -#include "configfile.h" #include #include @@ -63,7 +63,7 @@ static int wr_write (const data_set_t *ds, /* {{{ */ wr_node_t *node = ud->data; char ident[512]; char key[512]; - char value[512]; + char value[512] = { 0 }; char time[24]; size_t value_size; char *value_ptr; @@ -78,7 +78,6 @@ static int wr_write (const data_set_t *ds, /* {{{ */ ident); ssnprintf (time, sizeof (time), "%.9f", CDTIME_T_TO_DOUBLE(vl->time)); - memset (value, 0, sizeof (value)); value_size = sizeof (value); value_ptr = &value[0]; status = format_values (value_ptr, value_size, ds, vl, node->store_rates); @@ -92,7 +91,7 @@ static int wr_write (const data_set_t *ds, /* {{{ */ node->conn = redisConnectWithTimeout ((char *)node->host, node->port, node->timeout); if (node->conn == NULL) { - ERROR ("write_redis plugin: Connecting to host \"%s\" (port %i) failed: Unkown reason", + ERROR ("write_redis plugin: Connecting to host \"%s\" (port %i) failed: Unknown reason", (node->host != NULL) ? node->host : "localhost", (node->port != 0) ? node->port : 6379); pthread_mutex_unlock (&node->lock); @@ -168,7 +167,6 @@ static int wr_config_node (oconfig_item_t *ci) /* {{{ */ wr_node_t *node; int timeout; int status; - int i; node = calloc (1, sizeof (*node)); if (node == NULL) @@ -191,7 +189,7 @@ static int wr_config_node (oconfig_item_t *ci) /* {{{ */ return (status); } - for (i = 0; i < ci->children_num; i++) + for (int i = 0; i < ci->children_num; i++) { oconfig_item_t *child = ci->children + i; @@ -233,14 +231,14 @@ static int wr_config_node (oconfig_item_t *ci) /* {{{ */ if (status == 0) { char cb_name[DATA_MAX_NAME_LEN]; - user_data_t ud; ssnprintf (cb_name, sizeof (cb_name), "write_redis/%s", node->name); - ud.data = node; - ud.free_func = wr_config_free; - - status = plugin_register_write (cb_name, wr_write, &ud); + status = plugin_register_write (cb_name, wr_write, + &(user_data_t) { + .data = node, + .free_func = wr_config_free, + }); } if (status != 0) @@ -251,9 +249,7 @@ static int wr_config_node (oconfig_item_t *ci) /* {{{ */ static int wr_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;