Sentinel: receive Pub/Sub messages from slaves.

9f0e52a1 · antirez · f7604b4c · 9f0e52a1
显示空白变更内容
内联并排

Showing with 1 addition and 1 deletion

src/sentinel.c src/sentinel.c +1 -1

未找到文件。
--- a/src/sentinel.c
+++ b/src/sentinel.c
@@ -1336,7 +1336,7 @@ void sentinelReconnectInstance(sentinelRedisInstance *ri) {
        }
    }
    /* Pub / Sub */
-    if ((ri->flags & SRI_MASTER) && ri->pc == NULL) {
+    if ((ri->flags & (SRI_MASTER|SRI_SLAVE)) && ri->pc == NULL) {
        ri->pc = redisAsyncConnect(ri->addr->ip,ri->addr->port);
        if (ri->pc->err) {
            sentinelEvent(REDIS_DEBUG,"-pubsub-link-reconnection",ri,"%@ #%s",