Home
last modified time | relevance | path

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

/redis-3.2.3/src/
H A Dreplication.c392 slave->replstate = SLAVE_STATE_WAIT_BGSAVE_END; in replicationSetupSlaveForFullResync()
459 c->replstate = SLAVE_STATE_ONLINE; in masterTryPartialResynchronization()
621 c->replstate = SLAVE_STATE_WAIT_BGSAVE_START; in syncCommand()
784 slave->replstate = SLAVE_STATE_ONLINE; in putSlaveOnline()
878 if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_START) { in updateSlavesWaitingBgsave()
899 slave->replstate = SLAVE_STATE_ONLINE; in updateSlavesWaitingBgsave()
916 slave->replstate = SLAVE_STATE_SEND_BULK; in updateSlavesWaitingBgsave()
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()
[all …]
H A Dnetworking.c102 c->replstate = REPL_STATE_NONE; in createClient()
176 (c->replstate == REPL_STATE_NONE || in prepareClientToWrite()
177 (c->replstate == SLAVE_STATE_ONLINE && !c->repl_put_online_on_ack))) in prepareClientToWrite()
842 if (c->replstate == SLAVE_STATE_SEND_BULK) { in freeClient()
1849 slave->replstate == SLAVE_STATE_ONLINE && in flushSlavesOutputBuffers()
H A Drdb.c1527 if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_END) { in backgroundSaveDoneHandlerSocket()
1611 if (slave->replstate == SLAVE_STATE_WAIT_BGSAVE_START) { in rdbSaveToSlavesSockets()
1710 slave->replstate = SLAVE_STATE_WAIT_BGSAVE_START; in rdbSaveToSlavesSockets()
H A Daof.c582 c->replstate = SLAVE_STATE_WAIT_BGSAVE_START; in createFakeClient()
H A Dserver.h588 int replstate; /* Replication state if this is a slave. */ member
H A Dserver.c3205 switch(slave->replstate) { in genRedisInfoString()
3218 if (slave->replstate == SLAVE_STATE_ONLINE) in genRedisInfoString()