Lines Matching refs:clusterNode
47 clusterNode *myself = NULL;
49 clusterNode *createClusterNode(char *nodename, int flags);
50 int clusterAddNode(clusterNode *node);
55 void clusterSendFailoverAuthIfNeeded(clusterNode *node, clusterMsg *request);
57 int clusterNodeGetSlotBit(clusterNode *n, int slot);
59 clusterNode *clusterLookupNode(const char *name);
60 int clusterNodeAddSlave(clusterNode *master, clusterNode *slave);
61 int clusterAddSlot(clusterNode *n, int slot);
63 int clusterDelNodeSlots(clusterNode *node);
64 int clusterNodeSetSlotBit(clusterNode *n, int slot);
65 void clusterSetMaster(clusterNode *n);
70 void clusterSendUpdate(clusterLink *link, clusterNode *node);
73 void clusterSetNodeAsMaster(clusterNode *n);
74 void clusterDelNode(clusterNode *delnode);
126 clusterNode *n, *master; in clusterLoadConfig()
242 clusterNode *cn; in clusterLoadConfig()
553 clusterNode *node = dictGetVal(de); in clusterReset()
589 clusterLink *createClusterLink(clusterNode *node) { in createClusterLink()
694 clusterNode *createClusterNode(char *nodename, int flags) { in createClusterNode()
695 clusterNode *node = zmalloc(sizeof(*node)); in createClusterNode()
734 int clusterNodeAddFailureReport(clusterNode *failing, clusterNode *sender) { in clusterNodeAddFailureReport()
764 void clusterNodeCleanupFailureReports(clusterNode *node) { in clusterNodeCleanupFailureReports()
791 int clusterNodeDelFailureReport(clusterNode *node, clusterNode *sender) { in clusterNodeDelFailureReport()
814 int clusterNodeFailureReportsCount(clusterNode *node) { in clusterNodeFailureReportsCount()
819 int clusterNodeRemoveSlave(clusterNode *master, clusterNode *slave) { in clusterNodeRemoveSlave()
838 int clusterNodeAddSlave(clusterNode *master, clusterNode *slave) { in clusterNodeAddSlave()
845 sizeof(clusterNode*)*(master->numslaves+1)); in clusterNodeAddSlave()
852 int clusterCountNonFailingSlaves(clusterNode *n) { in clusterCountNonFailingSlaves()
861 void freeClusterNode(clusterNode *n) { in freeClusterNode()
886 int clusterAddNode(clusterNode *node) { in clusterAddNode()
905 void clusterDelNode(clusterNode *delnode) { in clusterDelNode()
923 clusterNode *node = dictGetVal(de); in clusterDelNode()
935 clusterNode *clusterLookupNode(const char *name) { in clusterLookupNode()
949 void clusterRenameNode(clusterNode *node, char *newname) { in clusterRenameNode()
975 clusterNode *node = dictGetVal(de); in clusterGetMaxEpoch()
1077 void clusterHandleConfigEpochCollision(clusterNode *sender) { in clusterHandleConfigEpochCollision()
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()
1282 clusterNode *n; in clusterStartHandshake()
1341 clusterNode *sender = link->node ? link->node : clusterLookupNode(hdr->sender); in clusterProcessGossipSection()
1345 clusterNode *node; in clusterProcessGossipSection()
1465 int nodeUpdateAddressIfNeeded(clusterNode *node, clusterLink *link, in nodeUpdateAddressIfNeeded()
1503 void clusterSetNodeAsMaster(clusterNode *n) { in clusterSetNodeAsMaster()
1530 void clusterUpdateSlotsConfigWith(clusterNode *sender, uint64_t senderConfigEpoch, unsigned char *s… in clusterUpdateSlotsConfigWith()
1532 clusterNode *curmaster, *newmaster = NULL; in clusterUpdateSlotsConfigWith()
1656 clusterNode *sender; in clusterProcessPacket()
1768 clusterNode *node; in clusterProcessPacket()
1892 clusterNode *master = clusterLookupNode(hdr->slaveof); in clusterProcessPacket()
1928 clusterNode *sender_master = NULL; /* Sender or its master if slave. */ in clusterProcessPacket()
2001 clusterNode *failing; in clusterProcessPacket()
2071 clusterNode *n; /* The node the update is about. */ in clusterProcessPacket()
2235 clusterNode *node = dictGetVal(de); in clusterBroadcastMessage()
2250 clusterNode *master; in clusterBuildMessageHdr()
2324 int clusterNodeIsInGossipSection(clusterMsg *hdr, int count, clusterNode *n) { in clusterNodeIsInGossipSection()
2335 void clusterSetGossipEntry(clusterMsg *hdr, int i, clusterNode *n) { in clusterSetGossipEntry()
2416 clusterNode *this = dictGetVal(de); in clusterSendPing()
2453 clusterNode *node = dictGetVal(de); in clusterSendPing()
2500 clusterNode *node = dictGetVal(de); in clusterBroadcastPong()
2576 void clusterSendUpdate(clusterLink *link, clusterNode *node) { in clusterSendUpdate()
2631 clusterNode *node = NULL; in clusterSendModuleMessageToTarget()
2680 void clusterSendFailoverAuth(clusterNode *node) { in clusterSendFailoverAuth()
2693 void clusterSendMFStart(clusterNode *node) { in clusterSendMFStart()
2706 void clusterSendFailoverAuthIfNeeded(clusterNode *node, clusterMsg *request) { in clusterSendFailoverAuthIfNeeded()
2707 clusterNode *master = node->slaveof; in clusterSendFailoverAuthIfNeeded()
2824 clusterNode *master; in clusterGetSlaveRank()
2910 clusterNode *oldmaster = myself->slaveof; in clusterFailoverReplaceYourMaster()
3146 clusterNode *mymaster = myself->slaveof, *target = NULL, *candidate = NULL; in clusterHandleSlaveMigration()
3174 clusterNode *node = dictGetVal(de); in clusterHandleSlaveMigration()
3317 clusterNode *min_pong_node = NULL; in clusterCron()
3368 clusterNode *node = dictGetVal(de); in clusterCron()
3445 clusterNode *this = dictGetVal(de); in clusterCron()
3473 clusterNode *node = dictGetVal(de); in clusterCron()
3654 clusterNode *node = dictGetVal(de); in clusterMastersHaveSlaves()
3664 int clusterNodeSetSlotBit(clusterNode *n, int slot) { in clusterNodeSetSlotBit()
3689 int clusterNodeClearSlotBit(clusterNode *n, int slot) { in clusterNodeClearSlotBit()
3697 int clusterNodeGetSlotBit(clusterNode *n, int slot) { in clusterNodeGetSlotBit()
3705 int clusterAddSlot(clusterNode *n, int slot) { in clusterAddSlot()
3716 clusterNode *n = server.cluster->slots[slot]; in clusterDelSlot()
3726 int clusterDelNodeSlots(clusterNode *node) { in clusterDelNodeSlots()
3806 clusterNode *node = dictGetVal(de); in clusterUpdateState()
3932 void clusterSetMaster(clusterNode *n) { in clusterSetMaster()
3989 sds clusterGenNodeDescription(clusterNode *node) { in clusterGenNodeDescription()
4073 clusterNode *node = dictGetVal(de); in clusterGenNodesDescription()
4135 clusterNode *node = dictGetVal(de); in clusterReplyMultiBulkSlots()
4331 clusterNode *n; in clusterCommand()
4369 clusterNode *n = clusterLookupNode(c->argv[4]->ptr); in clusterCommand()
4437 clusterNode *n = server.cluster->slots[j]; in clusterCommand()
4560 clusterNode *n = clusterLookupNode(c->argv[2]->ptr); in clusterCommand()
4579 clusterNode *n = clusterLookupNode(c->argv[2]->ptr); in clusterCommand()
4617 clusterNode *n = clusterLookupNode(c->argv[2]->ptr); in clusterCommand()
4641 clusterNode *n = clusterLookupNode(c->argv[2]->ptr); in clusterCommand()
5452 clusterNode *getNodeByQuery(client *c, struct redisCommand *cmd, robj **argv, int argc, int *hashsl… in getNodeByQuery()
5453 clusterNode *n = NULL; in getNodeByQuery()
5631 void clusterRedirectClient(client *c, clusterNode *n, int hashslot, int error_code) { in clusterRedirectClient()
5686 clusterNode *node = server.cluster->slots[slot]; in clusterRedirectBlockedClientIfNeeded()