Lines Matching defs:node
511 clusterNode *node = dictGetVal(de); in clusterReset() local
547 clusterLink *createClusterLink(clusterNode *node) { in createClusterLink()
654 clusterNode *node = zmalloc(sizeof(*node)); in createClusterNode() local
722 void clusterNodeCleanupFailureReports(clusterNode *node) { in clusterNodeCleanupFailureReports()
749 int clusterNodeDelFailureReport(clusterNode *node, clusterNode *sender) { in clusterNodeDelFailureReport()
772 int clusterNodeFailureReportsCount(clusterNode *node) { in clusterNodeFailureReportsCount()
844 int clusterAddNode(clusterNode *node) { in clusterAddNode()
881 clusterNode *node = dictGetVal(de); in clusterDelNode() local
907 void clusterRenameNode(clusterNode *node, char *newname) { in clusterRenameNode()
933 clusterNode *node = dictGetVal(de); in clusterGetMaxEpoch() local
1098 void clusterBlacklistAddNode(clusterNode *node) { in clusterBlacklistAddNode()
1151 void markNodeAsFailingIfNeeded(clusterNode *node) { in markNodeAsFailingIfNeeded()
1180 void clearNodeFailureIfNeeded(clusterNode *node) { in clearNodeFailureIfNeeded()
1221 clusterNode *node = dictGetVal(de); in clusterHandshakeInProgress() local
1300 clusterNode *node; in clusterProcessGossipSection() local
1383 int nodeUpdateAddressIfNeeded(clusterNode *node, clusterLink *link, int port) { in nodeUpdateAddressIfNeeded()
1665 clusterNode *node; in clusterProcessPacket() local
2104 clusterNode *node = dictGetVal(de); in clusterBroadcastMessage() local
2315 clusterNode *node = dictGetVal(de); in clusterBroadcastPong() local
2391 void clusterSendUpdate(clusterLink *link, clusterNode *node) { in clusterSendUpdate()
2440 void clusterSendFailoverAuth(clusterNode *node) { in clusterSendFailoverAuth()
2453 void clusterSendMFStart(clusterNode *node) { in clusterSendMFStart()
2466 void clusterSendFailoverAuthIfNeeded(clusterNode *node, clusterMsg *request) { in clusterSendFailoverAuthIfNeeded()
2928 clusterNode *node = dictGetVal(de); in clusterHandleSlaveMigration() local
3086 clusterNode *node = dictGetVal(de); in clusterCron() local
3187 clusterNode *node = dictGetVal(de); in clusterCron() local
3367 clusterNode *node = dictGetVal(de); in clusterMastersHaveSlaves() local
3439 int clusterDelNodeSlots(clusterNode *node) { in clusterDelNodeSlots()
3517 clusterNode *node = dictGetVal(de); in clusterUpdateState() local
3695 sds clusterGenNodeDescription(clusterNode *node) { in clusterGenNodeDescription()
3778 clusterNode *node = dictGetVal(de); in clusterGenNodesDescription() local
3824 clusterNode *node = dictGetVal(de); in clusterReplyMultiBulkSlots() local
5194 clusterNode *node = server.cluster->slots[slot]; in clusterRedirectBlockedClientIfNeeded() local