diff options
| -rw-r--r-- | src/blocked.c | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/blocked.c b/src/blocked.c index c4618a5cc..2ec2cf626 100644 --- a/src/blocked.c +++ b/src/blocked.c @@ -121,7 +121,7 @@ void processUnblockedClients(void) { * is blocked again. Actually processInputBuffer() checks that the * client is not blocked before to proceed, but things may change and * the code is conceptually more correct this way. */ - if (!(c->flags & DISQUE_BLOCKED)) { + if (!(c->flags & REDIS_BLOCKED)) { if (c->querybuf && sdslen(c->querybuf) > 0) { processInputBuffer(c); } |