Home
last modified time | relevance | path

Searched refs:replstate (Results 1 – 6 of 6) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Dreplication.c424 slave->replstate = SLAVE_STATE_WAIT_BGSAVE_END; in replicationSetupSlaveForFullResync()
510 c->replstate = SLAVE_STATE_ONLINE; in masterTryPartialResynchronization()
597 slave->replstate = REPL_STATE_NONE; in startBgsaveForReplication()
686 c->replstate = SLAVE_STATE_WAIT_BGSAVE_START; in syncCommand()
858 slave->replstate = SLAVE_STATE_ONLINE; in putSlaveOnline()
952 if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_START) { in updateSlavesWaitingBgsave()
973 slave->replstate = SLAVE_STATE_ONLINE; in updateSlavesWaitingBgsave()
990 slave->replstate = SLAVE_STATE_SEND_BULK; in updateSlavesWaitingBgsave()
2293 if (slave->replstate == SLAVE_STATE_ONLINE && in refreshGoodSlavesCount()
2428 if (slave->replstate != SLAVE_STATE_ONLINE) continue; in replicationCountAcksByOffset()
[all …]
H A Dnetworking.c128 c->replstate = REPL_STATE_NONE; in createClient()
176 (c->replstate == REPL_STATE_NONE || in clientInstallWriteHandler()
177 (c->replstate == SLAVE_STATE_ONLINE && !c->repl_put_online_on_ack))) in clientInstallWriteHandler()
818 (c->replstate == SLAVE_STATE_WAIT_BGSAVE_END)) { in unlinkClient()
910 if (c->replstate == SLAVE_STATE_SEND_BULK) { in freeClient()
2156 slave->replstate == SLAVE_STATE_ONLINE && in flushSlavesOutputBuffers()
H A Drdb.c2179 if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_END) { in backgroundSaveDoneHandlerSocket()
2263 if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_START) { in rdbSaveToSlavesSockets()
2364 slave->replstate = SLAVE_STATE_WAIT_BGSAVE_START; in rdbSaveToSlavesSockets()
H A Daof.c667 c->replstate = SLAVE_STATE_WAIT_BGSAVE_START; in createFakeClient()
H A Dserver.c3577 switch(slave->replstate) { in genRedisInfoString()
3590 if (slave->replstate == SLAVE_STATE_ONLINE) in genRedisInfoString()
H A Dserver.h742 int replstate; /* Replication state if this is a slave. */ member