projects
/
collectd.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Use a separate dequeue thread to dispatch notifications
[collectd.git]
/
src
/
write_redis.c
diff --git
a/src/write_redis.c
b/src/write_redis.c
index
d8cc94f
..
32005cd
100644
(file)
--- a/
src/write_redis.c
+++ b/
src/write_redis.c
@@
-72,7
+72,8
@@
static int wr_write(const data_set_t *ds, /* {{{ */
if (status != 0)
return status;
ssnprintf(key, sizeof(key), "%s%s",
if (status != 0)
return status;
ssnprintf(key, sizeof(key), "%s%s",
- (node->prefix != NULL) ? node->prefix : REDIS_DEFAULT_PREFIX, ident);
+ (node->prefix != NULL) ? node->prefix : REDIS_DEFAULT_PREFIX,
+ ident);
ssnprintf(time, sizeof(time), "%.9f", CDTIME_T_TO_DOUBLE(vl->time));
value_size = sizeof(value);
ssnprintf(time, sizeof(time), "%.9f", CDTIME_T_TO_DOUBLE(vl->time));
value_size = sizeof(value);
@@
-241,11
+242,11
@@
static int wr_config_node(oconfig_item_t *ci) /* {{{ */
ssnprintf(cb_name, sizeof(cb_name), "write_redis/%s", node->name);
ssnprintf(cb_name, sizeof(cb_name), "write_redis/%s", node->name);
- status =
- plugin_register_write(cb_name, wr_write,
- &(user_data_t){
-
.data = node,
.free_func = wr_config_free,
- });
+ status =
plugin_register_write(cb_name, wr_write,
+ &(user_data_t){
+ .data = node,
+
.free_func = wr_config_free,
+
});
}
if (status != 0)
}
if (status != 0)