Lines Matching refs:repl_state

635     if (server.masterhost && server.repl_state != REPL_STATE_CONNECTED) {  in syncCommand()
1047 return server.repl_state >= REPL_STATE_RECEIVE_PONG && in slaveIsInHandshakeState()
1048 server.repl_state <= REPL_STATE_RECEIVE_PSYNC; in slaveIsInHandshakeState()
1304 server.repl_state = REPL_STATE_CONNECTED; in readSyncBulkPayload()
1619 if (server.repl_state == REPL_STATE_NONE) { in syncWithMaster()
1635 if (server.repl_state == REPL_STATE_CONNECTING) { in syncWithMaster()
1640 server.repl_state = REPL_STATE_RECEIVE_PONG; in syncWithMaster()
1649 if (server.repl_state == REPL_STATE_RECEIVE_PONG) { in syncWithMaster()
1669 server.repl_state = REPL_STATE_SEND_AUTH; in syncWithMaster()
1673 if (server.repl_state == REPL_STATE_SEND_AUTH) { in syncWithMaster()
1677 server.repl_state = REPL_STATE_RECEIVE_AUTH; in syncWithMaster()
1680 server.repl_state = REPL_STATE_SEND_PORT; in syncWithMaster()
1685 if (server.repl_state == REPL_STATE_RECEIVE_AUTH) { in syncWithMaster()
1693 server.repl_state = REPL_STATE_SEND_PORT; in syncWithMaster()
1698 if (server.repl_state == REPL_STATE_SEND_PORT) { in syncWithMaster()
1706 server.repl_state = REPL_STATE_RECEIVE_PORT; in syncWithMaster()
1711 if (server.repl_state == REPL_STATE_RECEIVE_PORT) { in syncWithMaster()
1720 server.repl_state = REPL_STATE_SEND_IP; in syncWithMaster()
1724 if (server.repl_state == REPL_STATE_SEND_IP && in syncWithMaster()
1727 server.repl_state = REPL_STATE_SEND_CAPA; in syncWithMaster()
1732 if (server.repl_state == REPL_STATE_SEND_IP) { in syncWithMaster()
1737 server.repl_state = REPL_STATE_RECEIVE_IP; in syncWithMaster()
1742 if (server.repl_state == REPL_STATE_RECEIVE_IP) { in syncWithMaster()
1751 server.repl_state = REPL_STATE_SEND_CAPA; in syncWithMaster()
1760 if (server.repl_state == REPL_STATE_SEND_CAPA) { in syncWithMaster()
1765 server.repl_state = REPL_STATE_RECEIVE_CAPA; in syncWithMaster()
1770 if (server.repl_state == REPL_STATE_RECEIVE_CAPA) { in syncWithMaster()
1779 server.repl_state = REPL_STATE_SEND_PSYNC; in syncWithMaster()
1787 if (server.repl_state == REPL_STATE_SEND_PSYNC) { in syncWithMaster()
1792 server.repl_state = REPL_STATE_RECEIVE_PSYNC; in syncWithMaster()
1797 if (server.repl_state != REPL_STATE_RECEIVE_PSYNC) { in syncWithMaster()
1800 server.repl_state); in syncWithMaster()
1863 server.repl_state = REPL_STATE_TRANSFER; in syncWithMaster()
1877 server.repl_state = REPL_STATE_CONNECT; in syncWithMaster()
1907 server.repl_state = REPL_STATE_CONNECTING; in connectWithMaster()
1927 serverAssert(server.repl_state == REPL_STATE_TRANSFER); in replicationAbortSyncTransfer()
1943 if (server.repl_state == REPL_STATE_TRANSFER) { in cancelReplicationHandshake()
1945 server.repl_state = REPL_STATE_CONNECT; in cancelReplicationHandshake()
1946 } else if (server.repl_state == REPL_STATE_CONNECTING || in cancelReplicationHandshake()
1950 server.repl_state = REPL_STATE_CONNECT; in cancelReplicationHandshake()
1976 server.repl_state = REPL_STATE_CONNECT; in replicationSetMaster()
1997 server.repl_state = REPL_STATE_NONE; in replicationUnsetMaster()
2016 server.repl_state = REPL_STATE_CONNECT; in replicationHandleMasterDisconnection()
2117 switch(server.repl_state) { in roleCommand()
2253 server.repl_state = REPL_STATE_CONNECTED; in replicationResurrectCachedMaster()
2545 (server.repl_state == REPL_STATE_CONNECTING || in replicationCron()
2554 if (server.masterhost && server.repl_state == REPL_STATE_TRANSFER && in replicationCron()
2562 if (server.masterhost && server.repl_state == REPL_STATE_CONNECTED && in replicationCron()
2570 if (server.repl_state == REPL_STATE_CONNECT) { in replicationCron()