Commit 3c2800e3 authored by chendianqiang's avatar chendianqiang Committed by antirez
Browse files

stop ping when client pause

parent 7ac7ffd5
...@@ -2591,7 +2591,7 @@ void replicationCron(void) { ...@@ -2591,7 +2591,7 @@ void replicationCron(void) {
/* First, send PING according to ping_slave_period. */ /* First, send PING according to ping_slave_period. */
if ((replication_cron_loops % server.repl_ping_slave_period) == 0 && if ((replication_cron_loops % server.repl_ping_slave_period) == 0 &&
listLength(server.slaves)) listLength(server.slaves) && !clientsArePaused())
{ {
ping_argv[0] = createStringObject("PING",4); ping_argv[0] = createStringObject("PING",4);
replicationFeedSlaves(server.slaves, server.slaveseldb, replicationFeedSlaves(server.slaves, server.slaveseldb,
......
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