Lines Matching refs:slaves

122     serverAssert(listLength(server.slaves) == 0);  in freeReplicationBacklog()
173 void replicationFeedSlaves(list *slaves, int dictid, robj **argv, int argc) { in replicationFeedSlaves() argument
181 if (server.repl_backlog == NULL && listLength(slaves) == 0) return; in replicationFeedSlaves()
184 serverAssert(!(listLength(slaves) != 0 && server.repl_backlog == NULL)); in replicationFeedSlaves()
207 listRewind(slaves,&li); in replicationFeedSlaves()
247 listRewind(server.slaves,&li); in replicationFeedSlaves()
462 listAddNodeTail(server.slaves,c); in masterTryPartialResynchronization()
528 listRewind(server.slaves,&li); in startBgsaveForReplication()
534 listDelNode(server.slaves,ln); in startBgsaveForReplication()
546 listRewind(server.slaves,&li); in startBgsaveForReplication()
626 listAddNodeTail(server.slaves,c); in syncCommand()
639 listRewind(server.slaves,&li); in syncCommand()
689 if (listLength(server.slaves) == 1 && server.repl_backlog == NULL) in syncCommand()
874 listRewind(server.slaves,&li); in updateSlavesWaitingBgsave()
1747 if (listLength(server.slaves) == 0) { in replicationUnsetMaster()
1824 int slaves = 0; in roleCommand() local
1830 listRewind(server.slaves,&li); in roleCommand()
1845 slaves++; in roleCommand()
1847 setDeferredMultiBulkLength(c,mbcount,slaves); in roleCommand()
1989 listRewind(server.slaves,&li); in refreshGoodSlavesCount()
2125 listRewind(server.slaves,&li); in replicationCountAcksByOffset()
2292 replicationFeedSlaves(server.slaves, server.slaveseldb, in replicationCron()
2303 listRewind(server.slaves,&li); in replicationCron()
2318 if (listLength(server.slaves)) { in replicationCron()
2322 listRewind(server.slaves,&li); in replicationCron()
2339 if (listLength(server.slaves) == 0 && server.repl_backlog_time_limit && in replicationCron()
2356 if (listLength(server.slaves) == 0 && in replicationCron()
2376 listRewind(server.slaves,&li); in replicationCron()