Lines Matching refs:replstate

218             if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_START) continue;  in replicationFeedSlaves()
260 if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_START) continue; in replicationFeedSlaves()
299 if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_START) continue; in replicationFeedSlavesFromMasterStream()
424 slave->replstate = SLAVE_STATE_WAIT_BGSAVE_END; in replicationSetupSlaveForFullResync()
510 c->replstate = SLAVE_STATE_ONLINE; in masterTryPartialResynchronization()
596 if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_START) { in startBgsaveForReplication()
597 slave->replstate = REPL_STATE_NONE; in startBgsaveForReplication()
615 if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_START) { in startBgsaveForReplication()
686 c->replstate = SLAVE_STATE_WAIT_BGSAVE_START; in syncCommand()
717 if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_END) break; in syncCommand()
827 if (c->repl_put_online_on_ack && c->replstate == SLAVE_STATE_ONLINE) in replconfCommand()
858 slave->replstate = SLAVE_STATE_ONLINE; in putSlaveOnline()
952 if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_START) { in updateSlavesWaitingBgsave()
956 } else if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_END) { in updateSlavesWaitingBgsave()
973 slave->replstate = SLAVE_STATE_ONLINE; in updateSlavesWaitingBgsave()
990 slave->replstate = SLAVE_STATE_SEND_BULK; in updateSlavesWaitingBgsave()
2099 if (slave->replstate != SLAVE_STATE_ONLINE) continue; in roleCommand()
2293 if (slave->replstate == SLAVE_STATE_ONLINE && in refreshGoodSlavesCount()
2428 if (slave->replstate != SLAVE_STATE_ONLINE) continue; in replicationCountAcksByOffset()
2633 (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_START || in replicationCron()
2634 (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_END && in replicationCron()
2653 if (slave->replstate != SLAVE_STATE_ONLINE) continue; in replicationCron()
2727 if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_START) { in replicationCron()