redis plugin: Check for / report connection errors
authorPavel Rochnyack <pavel2000@ngs.ru>
Sun, 17 Jun 2018 09:10:54 +0000 (16:10 +0700)
committerPavel Rochnyack <pavel2000@ngs.ru>
Sun, 17 Jun 2018 12:13:39 +0000 (19:13 +0700)
src/redis.c

index 68158ed..9568fc5 100644 (file)
@@ -423,8 +423,13 @@ static int redis_read(void) /* {{{ */
 
     rh = redisConnectWithTimeout((char *)rn->host, rn->port, rn->timeout);
     if (rh == NULL) {
-      ERROR("redis plugin: unable to connect to node `%s' (%s:%d).", rn->name,
-            rn->host, rn->port);
+      ERROR("redis plugin: can't allocate redis context");
+      continue;
+    }
+    if (rh->err) {
+      ERROR("redis plugin: unable to connect to node `%s' (%s:%d): %s.",
+            rn->name, rn->host, rn->port, rh->errstr);
+      redisFree(rh);
       continue;
     }