Lines Matching refs:configEpoch

220         n->configEpoch = strtoull(argv[6],NULL,10);  in clusterLoadConfig()
524 myself->configEpoch = 0; in clusterReset()
661 node->configEpoch = 0; in createClusterNode()
934 if (node->configEpoch > max) max = node->configEpoch; in clusterGetMaxEpoch()
973 if (myself->configEpoch == 0 || in clusterBumpConfigEpochWithoutConsensus()
974 myself->configEpoch != maxEpoch) in clusterBumpConfigEpochWithoutConsensus()
977 myself->configEpoch = server.cluster->currentEpoch; in clusterBumpConfigEpochWithoutConsensus()
982 (unsigned long long) myself->configEpoch); in clusterBumpConfigEpochWithoutConsensus()
1037 if (sender->configEpoch != myself->configEpoch || in clusterHandleConfigEpochCollision()
1043 myself->configEpoch = server.cluster->currentEpoch; in clusterHandleConfigEpochCollision()
1049 (unsigned long long) myself->configEpoch); in clusterHandleConfigEpochCollision()
1481 server.cluster->slots[j]->configEpoch < senderConfigEpoch) in clusterUpdateSlotsConfigWith()
1604 senderConfigEpoch = ntohu64(hdr->configEpoch); in clusterProcessPacket()
1608 if (senderConfigEpoch > sender->configEpoch) { in clusterProcessPacket()
1609 sender->configEpoch = senderConfigEpoch; in clusterProcessPacket()
1853 if (server.cluster->slots[j]->configEpoch > in clusterProcessPacket()
1876 senderConfigEpoch == myself->configEpoch) in clusterProcessPacket()
1956 ntohu64(hdr->data.update.nodecfg.configEpoch); in clusterProcessPacket()
1961 if (n->configEpoch >= reportedConfigEpoch) return 1; /* Nothing new. */ in clusterProcessPacket()
1967 n->configEpoch = reportedConfigEpoch; in clusterProcessPacket()
2147 hdr->configEpoch = htonu64(master->configEpoch); in clusterBuildMessageHdr()
2398 hdr->data.update.nodecfg.configEpoch = htonu64(node->configEpoch); in clusterSendUpdate()
2469 uint64_t requestConfigEpoch = ntohu64(request->configEpoch); in clusterSendFailoverAuthIfNeeded()
2544 server.cluster->slots[j]->configEpoch <= requestConfigEpoch) in clusterSendFailoverAuthIfNeeded()
2555 (unsigned long long) server.cluster->slots[j]->configEpoch, in clusterSendFailoverAuthIfNeeded()
2857 if (myself->configEpoch < server.cluster->failover_auth_epoch) { in clusterHandleSlaveFailover()
2858 myself->configEpoch = server.cluster->failover_auth_epoch; in clusterHandleSlaveFailover()
2861 (unsigned long long) myself->configEpoch); in clusterHandleSlaveFailover()
3718 (unsigned long long) node->configEpoch, in clusterGenNodeDescription()
4078 (unsigned long long) myself->configEpoch); in clusterCommand()
4102 myself->slaveof->configEpoch : myself->configEpoch; in clusterCommand()
4341 } else if (myself->configEpoch != 0) { in clusterCommand()
4344 myself->configEpoch = epoch; in clusterCommand()
4347 (unsigned long long) myself->configEpoch); in clusterCommand()