diff options
| author | antirez <antirez@gmail.com> | 2018-06-19 15:53:32 +0200 |
|---|---|---|
| committer | antirez <antirez@gmail.com> | 2018-06-19 15:53:32 +0200 |
| commit | e94b2053c6cb00e604a0c9f0f51db78250400c36 (patch) | |
| tree | 56f1eb9d0ad2c5a9e7d6f0ab598848d947ee388f /src/cluster.c | |
| parent | ba92b517b8c22a4d62c583c0a6ac94fb9a0c2486 (diff) | |
| download | redis-e94b2053c6cb00e604a0c9f0f51db78250400c36.tar.gz | |
Modify clusterRedirectClient() to handle ZPOP and XREAD.
Diffstat (limited to 'src/cluster.c')
| -rw-r--r-- | src/cluster.c | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/cluster.c b/src/cluster.c index 17ba6a744..961241d47 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; |