Commit 2e1cd82d authored by zhaozhao.zz's avatar zhaozhao.zz Committed by antirez
Browse files

fix multiple unblock for clientsArePaused()

parent 17233080
...@@ -2134,9 +2134,9 @@ int clientsArePaused(void) { ...@@ -2134,9 +2134,9 @@ int clientsArePaused(void) {
while ((ln = listNext(&li)) != NULL) { while ((ln = listNext(&li)) != NULL) {
c = listNodeValue(ln); c = listNodeValue(ln);
/* Don't touch slaves and blocked clients. The latter pending /* Don't touch slaves and blocked or unblocked clients.
* requests be processed when unblocked. */ * The latter pending requests be processed when unblocked. */
if (c->flags & (CLIENT_SLAVE|CLIENT_BLOCKED)) continue; if (c->flags & (CLIENT_SLAVE|CLIENT_BLOCKED|CLIENT_UNBLOCKED)) continue;
c->flags |= CLIENT_UNBLOCKED; c->flags |= CLIENT_UNBLOCKED;
listAddNodeTail(server.unblocked_clients,c); listAddNodeTail(server.unblocked_clients,c);
} }
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment