Lines Matching refs:clusterNode
48 clusterNode *myself = NULL;
50 clusterNode *createClusterNode(char *nodename, int flags);
51 int clusterAddNode(clusterNode *node);
56 void clusterSendFailoverAuthIfNeeded(clusterNode *node, clusterMsg *request);
58 int clusterNodeGetSlotBit(clusterNode *n, int slot);
60 clusterNode *clusterLookupNode(char *name);
61 int clusterNodeAddSlave(clusterNode *master, clusterNode *slave);
62 int clusterAddSlot(clusterNode *n, int slot);
64 int clusterDelNodeSlots(clusterNode *node);
65 int clusterNodeSetSlotBit(clusterNode *n, int slot);
66 void clusterSetMaster(clusterNode *n);
71 void clusterSendUpdate(clusterLink *link, clusterNode *node);
74 void clusterSetNodeAsMaster(clusterNode *n);
75 void clusterDelNode(clusterNode *delnode);
126 clusterNode *n, *master; in clusterLoadConfig()
230 clusterNode *cn; in clusterLoadConfig()
511 clusterNode *node = dictGetVal(de); in clusterReset()
547 clusterLink *createClusterLink(clusterNode *node) { in createClusterLink()
653 clusterNode *createClusterNode(char *nodename, int flags) { in createClusterNode()
654 clusterNode *node = zmalloc(sizeof(*node)); in createClusterNode()
692 int clusterNodeAddFailureReport(clusterNode *failing, clusterNode *sender) { in clusterNodeAddFailureReport()
722 void clusterNodeCleanupFailureReports(clusterNode *node) { in clusterNodeCleanupFailureReports()
749 int clusterNodeDelFailureReport(clusterNode *node, clusterNode *sender) { in clusterNodeDelFailureReport()
772 int clusterNodeFailureReportsCount(clusterNode *node) { in clusterNodeFailureReportsCount()
777 int clusterNodeRemoveSlave(clusterNode *master, clusterNode *slave) { in clusterNodeRemoveSlave()
796 int clusterNodeAddSlave(clusterNode *master, clusterNode *slave) { in clusterNodeAddSlave()
803 sizeof(clusterNode*)*(master->numslaves+1)); in clusterNodeAddSlave()
810 int clusterCountNonFailingSlaves(clusterNode *n) { in clusterCountNonFailingSlaves()
819 void freeClusterNode(clusterNode *n) { in freeClusterNode()
844 int clusterAddNode(clusterNode *node) { in clusterAddNode()
863 void clusterDelNode(clusterNode *delnode) { in clusterDelNode()
881 clusterNode *node = dictGetVal(de); in clusterDelNode()
893 clusterNode *clusterLookupNode(char *name) { in clusterLookupNode()
907 void clusterRenameNode(clusterNode *node, char *newname) { in clusterRenameNode()
933 clusterNode *node = dictGetVal(de); in clusterGetMaxEpoch()
1035 void clusterHandleConfigEpochCollision(clusterNode *sender) { in clusterHandleConfigEpochCollision()
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()
1238 clusterNode *n; in clusterStartHandshake()
1296 clusterNode *sender = link->node ? link->node : clusterLookupNode(hdr->sender); in clusterProcessGossipSection()
1300 clusterNode *node; in clusterProcessGossipSection()
1383 int nodeUpdateAddressIfNeeded(clusterNode *node, clusterLink *link, int port) { in nodeUpdateAddressIfNeeded()
1415 void clusterSetNodeAsMaster(clusterNode *n) { in clusterSetNodeAsMaster()
1442 void clusterUpdateSlotsConfigWith(clusterNode *sender, uint64_t senderConfigEpoch, unsigned char *s… in clusterUpdateSlotsConfigWith()
1444 clusterNode *curmaster, *newmaster = NULL; in clusterUpdateSlotsConfigWith()
1561 clusterNode *sender; in clusterProcessPacket()
1665 clusterNode *node; in clusterProcessPacket()
1775 clusterNode *master = clusterLookupNode(hdr->slaveof); in clusterProcessPacket()
1811 clusterNode *sender_master = NULL; /* Sender or its master if slave. */ in clusterProcessPacket()
1884 clusterNode *failing; in clusterProcessPacket()
1954 clusterNode *n; /* The node the update is about. */ in clusterProcessPacket()
2104 clusterNode *node = dictGetVal(de); in clusterBroadcastMessage()
2119 clusterNode *master; in clusterBuildMessageHdr()
2237 clusterNode *this = dictGetVal(de); in clusterSendPing()
2315 clusterNode *node = dictGetVal(de); in clusterBroadcastPong()
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()
2467 clusterNode *master = node->slaveof; in clusterSendFailoverAuthIfNeeded()
2583 clusterNode *master; in clusterGetSlaveRank()
2668 clusterNode *oldmaster = myself->slaveof; in clusterFailoverReplaceYourMaster()
2900 clusterNode *mymaster = myself->slaveof, *target = NULL, *candidate = NULL; in clusterHandleSlaveMigration()
2928 clusterNode *node = dictGetVal(de); in clusterHandleSlaveMigration()
3070 clusterNode *min_pong_node = NULL; in clusterCron()
3086 clusterNode *node = dictGetVal(de); in clusterCron()
3159 clusterNode *this = dictGetVal(de); in clusterCron()
3187 clusterNode *node = dictGetVal(de); in clusterCron()
3367 clusterNode *node = dictGetVal(de); in clusterMastersHaveSlaves()
3377 int clusterNodeSetSlotBit(clusterNode *n, int slot) { in clusterNodeSetSlotBit()
3402 int clusterNodeClearSlotBit(clusterNode *n, int slot) { in clusterNodeClearSlotBit()
3410 int clusterNodeGetSlotBit(clusterNode *n, int slot) { in clusterNodeGetSlotBit()
3418 int clusterAddSlot(clusterNode *n, int slot) { in clusterAddSlot()
3429 clusterNode *n = server.cluster->slots[slot]; in clusterDelSlot()
3439 int clusterDelNodeSlots(clusterNode *node) { in clusterDelNodeSlots()
3517 clusterNode *node = dictGetVal(de); in clusterUpdateState()
3638 void clusterSetMaster(clusterNode *n) { in clusterSetMaster()
3695 sds clusterGenNodeDescription(clusterNode *node) { in clusterGenNodeDescription()
3778 clusterNode *node = dictGetVal(de); in clusterGenNodesDescription()
3824 clusterNode *node = dictGetVal(de); in clusterReplyMultiBulkSlots()
3982 clusterNode *n; in clusterCommand()
4020 clusterNode *n = clusterLookupNode(c->argv[4]->ptr); in clusterCommand()
4088 clusterNode *n = server.cluster->slots[j]; in clusterCommand()
4179 clusterNode *n = clusterLookupNode(c->argv[2]->ptr); in clusterCommand()
4198 clusterNode *n = clusterLookupNode(c->argv[2]->ptr); in clusterCommand()
4235 clusterNode *n = clusterLookupNode(c->argv[2]->ptr); in clusterCommand()
4259 clusterNode *n = clusterLookupNode(c->argv[2]->ptr); in clusterCommand()
4974 clusterNode *getNodeByQuery(client *c, struct redisCommand *cmd, robj **argv, int argc, int *hashsl… in getNodeByQuery()
4975 clusterNode *n = NULL; in getNodeByQuery()
5144 void clusterRedirectClient(client *c, clusterNode *n, int hashslot, int error_code) { in clusterRedirectClient()
5194 clusterNode *node = server.cluster->slots[slot]; in clusterRedirectBlockedClientIfNeeded()