Lines Matching refs:repl_state

570     if (server.masterhost && server.repl_state != REPL_STATE_CONNECTED) {  in syncCommand()
936 return server.repl_state >= REPL_STATE_RECEIVE_PONG && in slaveIsInHandshakeState()
937 server.repl_state <= REPL_STATE_RECEIVE_PSYNC; in slaveIsInHandshakeState()
972 server.repl_state = REPL_STATE_CONNECTED; in replicationCreateMasterClient()
1397 if (server.repl_state == REPL_STATE_NONE) { in syncWithMaster()
1412 if (server.repl_state == REPL_STATE_CONNECTING) { in syncWithMaster()
1417 server.repl_state = REPL_STATE_RECEIVE_PONG; in syncWithMaster()
1426 if (server.repl_state == REPL_STATE_RECEIVE_PONG) { in syncWithMaster()
1446 server.repl_state = REPL_STATE_SEND_AUTH; in syncWithMaster()
1450 if (server.repl_state == REPL_STATE_SEND_AUTH) { in syncWithMaster()
1454 server.repl_state = REPL_STATE_RECEIVE_AUTH; in syncWithMaster()
1457 server.repl_state = REPL_STATE_SEND_PORT; in syncWithMaster()
1462 if (server.repl_state == REPL_STATE_RECEIVE_AUTH) { in syncWithMaster()
1470 server.repl_state = REPL_STATE_SEND_PORT; in syncWithMaster()
1475 if (server.repl_state == REPL_STATE_SEND_PORT) { in syncWithMaster()
1483 server.repl_state = REPL_STATE_RECEIVE_PORT; in syncWithMaster()
1488 if (server.repl_state == REPL_STATE_RECEIVE_PORT) { in syncWithMaster()
1497 server.repl_state = REPL_STATE_SEND_IP; in syncWithMaster()
1501 if (server.repl_state == REPL_STATE_SEND_IP && in syncWithMaster()
1504 server.repl_state = REPL_STATE_SEND_CAPA; in syncWithMaster()
1509 if (server.repl_state == REPL_STATE_SEND_IP) { in syncWithMaster()
1514 server.repl_state = REPL_STATE_RECEIVE_IP; in syncWithMaster()
1519 if (server.repl_state == REPL_STATE_RECEIVE_IP) { in syncWithMaster()
1528 server.repl_state = REPL_STATE_SEND_CAPA; in syncWithMaster()
1535 if (server.repl_state == REPL_STATE_SEND_CAPA) { in syncWithMaster()
1540 server.repl_state = REPL_STATE_RECEIVE_CAPA; in syncWithMaster()
1545 if (server.repl_state == REPL_STATE_RECEIVE_CAPA) { in syncWithMaster()
1554 server.repl_state = REPL_STATE_SEND_PSYNC; in syncWithMaster()
1562 if (server.repl_state == REPL_STATE_SEND_PSYNC) { in syncWithMaster()
1567 server.repl_state = REPL_STATE_RECEIVE_PSYNC; in syncWithMaster()
1572 if (server.repl_state != REPL_STATE_RECEIVE_PSYNC) { in syncWithMaster()
1575 server.repl_state); in syncWithMaster()
1632 server.repl_state = REPL_STATE_TRANSFER; in syncWithMaster()
1645 server.repl_state = REPL_STATE_CONNECT; in syncWithMaster()
1675 server.repl_state = REPL_STATE_CONNECTING; in connectWithMaster()
1695 serverAssert(server.repl_state == REPL_STATE_TRANSFER); in replicationAbortSyncTransfer()
1711 if (server.repl_state == REPL_STATE_TRANSFER) { in cancelReplicationHandshake()
1713 server.repl_state = REPL_STATE_CONNECT; in cancelReplicationHandshake()
1714 } else if (server.repl_state == REPL_STATE_CONNECTING || in cancelReplicationHandshake()
1718 server.repl_state = REPL_STATE_CONNECT; in cancelReplicationHandshake()
1736 server.repl_state = REPL_STATE_CONNECT; in replicationSetMaster()
1759 server.repl_state = REPL_STATE_NONE; in replicationUnsetMaster()
1766 server.repl_state = REPL_STATE_CONNECT; in replicationHandleMasterDisconnection()
1858 switch(server.repl_state) { in roleCommand()
1955 server.repl_state = REPL_STATE_CONNECTED; in replicationResurrectCachedMaster()
2241 (server.repl_state == REPL_STATE_CONNECTING || in replicationCron()
2250 if (server.masterhost && server.repl_state == REPL_STATE_TRANSFER && in replicationCron()
2258 if (server.masterhost && server.repl_state == REPL_STATE_CONNECTED && in replicationCron()
2266 if (server.repl_state == REPL_STATE_CONNECT) { in replicationCron()