X-Git-Url: https://git.tokkee.org/?a=blobdiff_plain;f=src%2Fwrite_sensu.c;h=1956458cb504ddd1684f9639300c9ed6dc8342d4;hb=94d84b7b773e9d140b81699d1d42a9e461a5b76d;hp=cb0c2fe2dc4ce8cac97f7cb7fc7ef7f82bdb21a5;hpb=0beb06563c5681975fd4f743c547e15f4facb29f;p=collectd.git diff --git a/src/write_sensu.c b/src/write_sensu.c index cb0c2fe2..1956458c 100644 --- a/src/write_sensu.c +++ b/src/write_sensu.c @@ -47,7 +47,7 @@ #include #include -int vasprintf(char **str, const char *fmt, va_list args) { +static int vasprintf(char **str, const char *fmt, va_list args) { int size = 0; va_list tmpa; // copy @@ -113,8 +113,8 @@ struct sensu_host { int reference_count; }; -static char *sensu_tags; -static char **sensu_attrs; +static char *sensu_tags = NULL; +static char **sensu_attrs = NULL; static size_t sensu_attrs_num; static int add_str_to_list(struct str_list *strs, @@ -259,7 +259,7 @@ static char *build_json_str_list(const char *tag, struct str_list const *list) / return ret_str; } /* }}} char *build_json_str_list*/ -int sensu_format_name2(char *ret, int ret_len, +static int sensu_format_name2(char *ret, int ret_len, const char *hostname, const char *plugin, const char *plugin_instance, const char *type, const char *type_instance, @@ -456,7 +456,7 @@ static char *sensu_value_to_json(struct sensu_host const *host, /* {{{ */ } // incorporate sensu tags from config if any - if (strlen(sensu_tags) != 0) { + if ((sensu_tags != NULL) && (strlen(sensu_tags) != 0)) { res = asprintf(&temp_str, "%s, %s", ret_str, sensu_tags); free(ret_str); if (res == -1) { @@ -468,16 +468,14 @@ static char *sensu_value_to_json(struct sensu_host const *host, /* {{{ */ // calculate the value and set to a string if (ds->ds[index].type == DS_TYPE_GAUGE) { - double tmp_v = (double) vl->values[index].gauge; - res = asprintf(&value_str, "%.8f", tmp_v); + res = asprintf(&value_str, GAUGE_FORMAT, vl->values[index].gauge); if (res == -1) { free(ret_str); ERROR("write_sensu plugin: Unable to alloc memory"); return NULL; } } else if (rates != NULL) { - double tmp_v = (double) rates[index]; - res = asprintf(&value_str, "%.8f", tmp_v); + res = asprintf(&value_str, GAUGE_FORMAT, rates[index]); if (res == -1) { free(ret_str); ERROR("write_sensu plugin: Unable to alloc memory"); @@ -553,14 +551,14 @@ static char *sensu_value_to_json(struct sensu_host const *host, /* {{{ */ * http://creativeandcritical.net/str-replace-c/ * copyright (c) Laird Shaw, under public domain. */ -char *replace_str(const char *str, const char *old, /* {{{ */ +static char *replace_str(const char *str, const char *old, /* {{{ */ const char *new) { char *ret, *r; const char *p, *q; size_t oldlen = strlen(old); size_t count = strlen(new); - size_t retlen = count; + size_t retlen; size_t newlen = count; int samesize = (oldlen == newlen); @@ -682,6 +680,7 @@ static char *sensu_notification_to_json(struct sensu_host *host, /* {{{ */ char *handlers_str = build_json_str_list("handlers", &(host->notification_handlers)); if (handlers_str == NULL) { ERROR("write_sensu plugin: Unable to alloc memory"); + free(ret_str); return NULL; } // incorporate the handlers @@ -754,7 +753,7 @@ static char *sensu_notification_to_json(struct sensu_host *host, /* {{{ */ } // incorporate sensu tags from config if any - if (strlen(sensu_tags) != 0) { + if ((sensu_tags != NULL) && (strlen(sensu_tags) != 0)) { res = asprintf(&temp_str, "%s, %s", ret_str, sensu_tags); free(ret_str); if (res == -1) { @@ -783,6 +782,7 @@ static char *sensu_notification_to_json(struct sensu_host *host, /* {{{ */ char *msg = replace_json_reserved(n->message); if (msg == NULL) { ERROR("write_sensu plugin: Unable to alloc memory"); + free(ret_str); return NULL; } res = asprintf(&temp_str, "%s, \"output\": \"%s - %s\"", ret_str, severity, msg); @@ -1162,12 +1162,6 @@ static int sensu_config(oconfig_item_t *ci) /* {{{ */ sensu_tags_arr.nb_strs = 0; sensu_tags_arr.strs = NULL; - sensu_tags = malloc(sizeof(char)); - if (sensu_tags == NULL) { - ERROR("write_sensu plugin: Unable to alloc memory"); - return -1; - } - sensu_tags[0] = '\0'; for (i = 0; i < ci->children_num; i++) { child = &ci->children[i]; @@ -1175,36 +1169,22 @@ static int sensu_config(oconfig_item_t *ci) /* {{{ */ if (strcasecmp("Node", child->key) == 0) { sensu_config_node(child); } else if (strcasecmp(child->key, "attribute") == 0) { - char *key = NULL; - char *val = NULL; - if (child->values_num != 2) { WARNING("sensu attributes need both a key and a value."); - free(sensu_tags); - return -1; + continue; } if (child->values[0].type != OCONFIG_TYPE_STRING || - child->values[1].type != OCONFIG_TYPE_STRING) { + child->values[1].type != OCONFIG_TYPE_STRING) { WARNING("sensu attribute needs string arguments."); - free(sensu_tags); - return -1; - } - if ((key = strdup(child->values[0].value.string)) == NULL) { - ERROR("write_sensu plugin: Unable to alloc memory"); - free(sensu_tags); - return -1; - } - if ((val = strdup(child->values[1].value.string)) == NULL) { - free(sensu_tags); - free(key); - ERROR("write_sensu plugin: Unable to alloc memory"); - return -1; + continue; } - strarray_add(&sensu_attrs, &sensu_attrs_num, key); - strarray_add(&sensu_attrs, &sensu_attrs_num, val); - DEBUG("write_sensu: got attr: %s => %s", key, val); - sfree(key); - sfree(val); + + strarray_add(&sensu_attrs, &sensu_attrs_num, child->values[0].value.string); + strarray_add(&sensu_attrs, &sensu_attrs_num, child->values[1].value.string); + + DEBUG("write_sensu plugin: New attribute: %s => %s", + child->values[0].value.string, + child->values[1].value.string); } else if (strcasecmp(child->key, "tag") == 0) { char *tmp = NULL; status = cf_util_get_string(child, &tmp); @@ -1223,7 +1203,7 @@ static int sensu_config(oconfig_item_t *ci) /* {{{ */ } } if (sensu_tags_arr.nb_strs > 0) { - free(sensu_tags); + sfree (sensu_tags); sensu_tags = build_json_str_list("tags", &sensu_tags_arr); free_str_list(&sensu_tags_arr); if (sensu_tags == NULL) {