X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Fwrite_tsdb.c;h=b670f3ae583d3d401565c019ed5df900667f87b8;hb=0a8741b9061f8df4a78a448c021612db06e17425;hp=309418a185ee2261ba8fdd79331afd4e59939297;hpb=f8e1e81d433c5b4e06792c2617abf0e6ec9e76d9;p=collectd.git diff --git a/src/write_tsdb.c b/src/write_tsdb.c index 309418a1..b670f3ae 100644 --- a/src/write_tsdb.c +++ b/src/write_tsdb.c @@ -45,7 +45,6 @@ #include "common.h" #include "plugin.h" -#include "configfile.h" #include "utils_cache.h" @@ -187,6 +186,8 @@ static int wt_callback_init(struct wt_callback *cb) if (cb->sock_fd < 0) continue; + set_sock_opts(cb->sock_fd); + status = connect(cb->sock_fd, ai_ptr->ai_addr, ai_ptr->ai_addrlen); if (status != 0) { @@ -569,7 +570,6 @@ 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 = { 0 }; char callback_name[DATA_MAX_NAME_LEN]; cb = calloc(1, sizeof(*cb)); @@ -611,8 +611,11 @@ 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); - user_data.data = cb; - user_data.free_func = wt_callback_free; + user_data_t user_data = { + .data = cb, + .free_func = wt_callback_free + }; + plugin_register_write(callback_name, wt_write, &user_data); user_data.free_func = NULL;