From e44afcf744af2337983b41c6e7a3617595692ddd Mon Sep 17 00:00:00 2001 From: biancalana Date: Thu, 5 Jul 2012 23:10:24 -0300 Subject: [PATCH] redis plugin: Add authentication support. --- src/redis.c | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/src/redis.c b/src/redis.c index b694e09d..9d26828e 100644 --- a/src/redis.c +++ b/src/redis.c @@ -50,6 +50,7 @@ struct redis_node_s { char name[MAX_REDIS_NODE_NAME]; char host[HOST_NAME_MAX]; + char passwd[HOST_NAME_MAX]; int port; int timeout; @@ -132,6 +133,8 @@ static int redis_config_node (oconfig_item_t *ci) /* {{{ */ } else if (strcasecmp ("Timeout", option->key) == 0) status = cf_util_get_int (option, &rn.timeout); + else if (strcasecmp ("Passwd", option->key) == 0) + status = cf_util_get_string_buffer (option, rn.passwd, sizeof (rn.passwd)); else WARNING ("redis plugin: Option `%s' not allowed inside a `Node' " "block. I'll ignore this option.", option->key); @@ -251,6 +254,16 @@ static int redis_read (void) /* {{{ */ continue; } + if ( strlen(rn->passwd) > 0 ) { + DEBUG ("redis plugin: authenticanting node `%s' passwd(%s).", rn->name, rn->passwd); + if ( credis_auth(rh, rn->passwd) != 0 ) + { + WARNING ("redis plugin: unable to authenticate on node `%s'.", rn->name); + credis_close (rh); + continue; + } + } + memset (&info, 0, sizeof (info)); status = credis_info (rh, &info); if (status != 0) -- 2.30.2