Comment clearly why we moved some code in #6623.
This commit is contained in:
parent
4024bc7eee
commit
d2a6c5ffa2
@ -2124,7 +2124,10 @@ void beforeSleep(struct aeEventLoop *eventLoop) {
|
|||||||
processUnblockedClients();
|
processUnblockedClients();
|
||||||
|
|
||||||
/* Send all the slaves an ACK request if at least one client blocked
|
/* Send all the slaves an ACK request if at least one client blocked
|
||||||
* during the previous event loop iteration. */
|
* during the previous event loop iteration. Note that we do this after
|
||||||
|
* processUnblockedClients(), so if there are multiple pipelined WAITs
|
||||||
|
* and the just unblocked WAIT gets blocked again, we don't have to wait
|
||||||
|
* a server cron cycle in absence of other event loop events. See #6623. */
|
||||||
if (server.get_ack_from_slaves) {
|
if (server.get_ack_from_slaves) {
|
||||||
robj *argv[3];
|
robj *argv[3];
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user