Lines Matching refs:replstate
210 if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_START) continue; in replicationFeedSlaves()
252 if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_START) continue; in replicationFeedSlaves()
392 slave->replstate = SLAVE_STATE_WAIT_BGSAVE_END; in replicationSetupSlaveForFullResync()
459 c->replstate = SLAVE_STATE_ONLINE; in masterTryPartialResynchronization()
532 if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_START) { in startBgsaveForReplication()
550 if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_START) { in startBgsaveForReplication()
621 c->replstate = SLAVE_STATE_WAIT_BGSAVE_START; in syncCommand()
642 if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_END) break; in syncCommand()
753 if (c->repl_put_online_on_ack && c->replstate == SLAVE_STATE_ONLINE) in replconfCommand()
784 slave->replstate = SLAVE_STATE_ONLINE; in putSlaveOnline()
878 if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_START) { in updateSlavesWaitingBgsave()
882 } else if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_END) { in updateSlavesWaitingBgsave()
899 slave->replstate = SLAVE_STATE_ONLINE; in updateSlavesWaitingBgsave()
916 slave->replstate = SLAVE_STATE_SEND_BULK; in updateSlavesWaitingBgsave()
1840 if (slave->replstate != SLAVE_STATE_ONLINE) continue; in roleCommand()
1994 if (slave->replstate == SLAVE_STATE_ONLINE && in refreshGoodSlavesCount()
2129 if (slave->replstate != SLAVE_STATE_ONLINE) continue; in replicationCountAcksByOffset()
2307 if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_START || in replicationCron()
2308 (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_END && in replicationCron()
2326 if (slave->replstate != SLAVE_STATE_ONLINE) continue; in replicationCron()
2379 if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_START) { in replicationCron()