From e94b2053c6cb00e604a0c9f0f51db78250400c36 Mon Sep 17 00:00:00 2001 From: antirez Date: Tue, 19 Jun 2018 15:53:32 +0200 Subject: [PATCH] Modify clusterRedirectClient() to handle ZPOP and XREAD. --- src/cluster.c | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/cluster.c b/src/cluster.c index 17ba6a74..961241d4 100644 --- a/src/cluster.c +++ b/src/cluster.c @@ -5589,7 +5589,11 @@ void clusterRedirectClient(client *c, clusterNode *n, int hashslot, int error_co * longer handles, the client is sent a redirection error, and the function * returns 1. Otherwise 0 is returned and no operation is performed. */ int clusterRedirectBlockedClientIfNeeded(client *c) { - if (c->flags & CLIENT_BLOCKED && c->btype == BLOCKED_LIST) { + if (c->flags & CLIENT_BLOCKED && + (c->btype == BLOCKED_LIST || + c->btype == BLOCKED_ZSET || + c->btype == BLOCKED_STREAM)) + { dictEntry *de; dictIterator *di;