projects
/
collectd.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge branch 'collectd-4.10' into collectd-5.0
[collectd.git]
/
src
/
write_redis.c
diff --git
a/src/write_redis.c
b/src/write_redis.c
index
c995a90
..
58f2cae
100644
(file)
--- a/
src/write_redis.c
+++ b/
src/write_redis.c
@@
-53,6
+53,7
@@
static int wr_write (const data_set_t *ds, /* {{{ */
user_data_t *ud)
{
wr_node_t *node = ud->data;
user_data_t *ud)
{
wr_node_t *node = ud->data;
+ char ident[512];
char key[512];
char value[512];
size_t value_size;
char key[512];
char value[512];
size_t value_size;
@@
-60,10
+61,10
@@
static int wr_write (const data_set_t *ds, /* {{{ */
int status;
int i;
int status;
int i;
- status = FORMAT_VL (
value, sizeof (value
), vl);
+ status = FORMAT_VL (
ident, sizeof (ident
), vl);
if (status != 0)
return (status);
if (status != 0)
return (status);
- ssnprintf (key, sizeof (key), "collectd/%s",
value
);
+ ssnprintf (key, sizeof (key), "collectd/%s",
ident
);
memset (value, 0, sizeof (value));
value_size = sizeof (value);
memset (value, 0, sizeof (value));
value_size = sizeof (value);
@@
-120,6
+121,8
@@
static int wr_write (const data_set_t *ds, /* {{{ */
assert (node->conn != NULL);
status = credis_zadd (node->conn, key, (double) vl->time, value);
assert (node->conn != NULL);
status = credis_zadd (node->conn, key, (double) vl->time, value);
+ credis_sadd (node->conn, "collectd/values", ident);
+
pthread_mutex_unlock (&node->lock);
return (0);
pthread_mutex_unlock (&node->lock);
return (0);