Lines Matching defs:node

553         clusterNode *node = dictGetVal(de);  in clusterReset()  local
589 clusterLink *createClusterLink(clusterNode *node) { in createClusterLink()
695 clusterNode *node = zmalloc(sizeof(*node)); in createClusterNode() local
764 void clusterNodeCleanupFailureReports(clusterNode *node) { in clusterNodeCleanupFailureReports()
791 int clusterNodeDelFailureReport(clusterNode *node, clusterNode *sender) { in clusterNodeDelFailureReport()
814 int clusterNodeFailureReportsCount(clusterNode *node) { in clusterNodeFailureReportsCount()
886 int clusterAddNode(clusterNode *node) { in clusterAddNode()
923 clusterNode *node = dictGetVal(de); in clusterDelNode() local
949 void clusterRenameNode(clusterNode *node, char *newname) { in clusterRenameNode()
975 clusterNode *node = dictGetVal(de); in clusterGetMaxEpoch() local
1140 void clusterBlacklistAddNode(clusterNode *node) { in clusterBlacklistAddNode()
1193 void markNodeAsFailingIfNeeded(clusterNode *node) { in markNodeAsFailingIfNeeded()
1222 void clearNodeFailureIfNeeded(clusterNode *node) { in clearNodeFailureIfNeeded()
1263 clusterNode *node = dictGetVal(de); in clusterHandshakeInProgress() local
1345 clusterNode *node; in clusterProcessGossipSection() local
1465 int nodeUpdateAddressIfNeeded(clusterNode *node, clusterLink *link, in nodeUpdateAddressIfNeeded()
1768 clusterNode *node; in clusterProcessPacket() local
2235 clusterNode *node = dictGetVal(de); in clusterBroadcastMessage() local
2453 clusterNode *node = dictGetVal(de); in clusterSendPing() local
2500 clusterNode *node = dictGetVal(de); in clusterBroadcastPong() local
2576 void clusterSendUpdate(clusterLink *link, clusterNode *node) { in clusterSendUpdate()
2631 clusterNode *node = NULL; in clusterSendModuleMessageToTarget() local
2680 void clusterSendFailoverAuth(clusterNode *node) { in clusterSendFailoverAuth()
2693 void clusterSendMFStart(clusterNode *node) { in clusterSendMFStart()
2706 void clusterSendFailoverAuthIfNeeded(clusterNode *node, clusterMsg *request) { in clusterSendFailoverAuthIfNeeded()
3174 clusterNode *node = dictGetVal(de); in clusterHandleSlaveMigration() local
3368 clusterNode *node = dictGetVal(de); in clusterCron() local
3473 clusterNode *node = dictGetVal(de); in clusterCron() local
3654 clusterNode *node = dictGetVal(de); in clusterMastersHaveSlaves() local
3726 int clusterDelNodeSlots(clusterNode *node) { in clusterDelNodeSlots()
3806 clusterNode *node = dictGetVal(de); in clusterUpdateState() local
3989 sds clusterGenNodeDescription(clusterNode *node) { in clusterGenNodeDescription()
4073 clusterNode *node = dictGetVal(de); in clusterGenNodesDescription() local
4135 clusterNode *node = dictGetVal(de); in clusterReplyMultiBulkSlots() local
5686 clusterNode *node = server.cluster->slots[slot]; in clusterRedirectBlockedClientIfNeeded() local