Lines Matching refs:currentEpoch

143                     server.cluster->currentEpoch =  in clusterLoadConfig()
272 if (clusterGetMaxEpoch() > server.cluster->currentEpoch) { in clusterLoadConfig()
273 server.cluster->currentEpoch = clusterGetMaxEpoch(); in clusterLoadConfig()
309 (unsigned long long) server.cluster->currentEpoch, in clusterSaveConfig()
403 server.cluster->currentEpoch = 0; in clusterInit()
522 server.cluster->currentEpoch = 0; in clusterReset()
937 if (max < server.cluster->currentEpoch) max = server.cluster->currentEpoch; in clusterGetMaxEpoch()
976 server.cluster->currentEpoch++; in clusterBumpConfigEpochWithoutConsensus()
977 myself->configEpoch = server.cluster->currentEpoch; in clusterBumpConfigEpochWithoutConsensus()
1042 server.cluster->currentEpoch++; in clusterHandleConfigEpochCollision()
1043 myself->configEpoch = server.cluster->currentEpoch; in clusterHandleConfigEpochCollision()
1603 senderCurrentEpoch = ntohu64(hdr->currentEpoch); in clusterProcessPacket()
1605 if (senderCurrentEpoch > server.cluster->currentEpoch) in clusterProcessPacket()
1606 server.cluster->currentEpoch = senderCurrentEpoch; in clusterProcessPacket()
2146 hdr->currentEpoch = htonu64(server.cluster->currentEpoch); in clusterBuildMessageHdr()
2468 uint64_t requestCurrentEpoch = ntohu64(request->currentEpoch); in clusterSendFailoverAuthIfNeeded()
2484 if (requestCurrentEpoch < server.cluster->currentEpoch) { in clusterSendFailoverAuthIfNeeded()
2489 (unsigned long long) server.cluster->currentEpoch); in clusterSendFailoverAuthIfNeeded()
2494 if (server.cluster->lastVoteEpoch == server.cluster->currentEpoch) { in clusterSendFailoverAuthIfNeeded()
2498 (unsigned long long) server.cluster->currentEpoch); in clusterSendFailoverAuthIfNeeded()
2562 server.cluster->lastVoteEpoch = server.cluster->currentEpoch; in clusterSendFailoverAuthIfNeeded()
2565 node->name, (unsigned long long) server.cluster->currentEpoch); in clusterSendFailoverAuthIfNeeded()
2837 server.cluster->currentEpoch++; in clusterHandleSlaveFailover()
2838 server.cluster->failover_auth_epoch = server.cluster->currentEpoch; in clusterHandleSlaveFailover()
2840 (unsigned long long) server.cluster->currentEpoch); in clusterHandleSlaveFailover()
4123 (unsigned long long) server.cluster->currentEpoch, in clusterCommand()
4349 if (server.cluster->currentEpoch < (uint64_t)epoch) in clusterCommand()
4350 server.cluster->currentEpoch = epoch; in clusterCommand()