caleb-brown/redict
1
0
Fork 0
mirror of https://codeberg.org/redict/redict.git synced 2025-01-23 08:38:27 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #4418 from soloestoy/fix-multiple-unblock

Browse Source 
fix multiple unblock for clientsArePaused()
This commit is contained in:
Salvatore Sanfilippo 2018-09-03 18:31:02 +02:00 committed by GitHub
commit 2b689ad641
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/networking.c
View File

@ -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);
} }

2
src/scripting.c
View File

@ -1367,7 +1367,7 @@ void evalGenericCommand(client *c, int evalsha) {
* script timeout was detected. */ * script timeout was detected. */
aeCreateFileEvent(server.el,c->fd,AE_READABLE, aeCreateFileEvent(server.el,c->fd,AE_READABLE,
readQueryFromClient,c); readQueryFromClient,c);
if (server.masterhost && server.master) { if (server.masterhost && server.master && !(server.master->flags & CLIENT_UNBLOCKED)) {
server.master->flags |= CLIENT_UNBLOCKED; server.master->flags |= CLIENT_UNBLOCKED;
listAddNodeTail(server.unblocked_clients,server.master); listAddNodeTail(server.unblocked_clients,server.master);
} }