Lines Matching refs:clusterLink
54 void clusterSendPing(clusterLink *link, int type);
71 void clusterSendUpdate(clusterLink *link, clusterNode *node);
547 clusterLink *createClusterLink(clusterNode *node) { in createClusterLink()
548 clusterLink *link = zmalloc(sizeof(*link)); in createClusterLink()
560 void freeClusterLink(clusterLink *link) { in freeClusterLink()
578 clusterLink *link; in clusterAcceptHandler()
1293 void clusterProcessGossipSection(clusterMsg *hdr, clusterLink *link) { in clusterProcessGossipSection()
1369 void nodeIp2String(char *buf, clusterLink *link) { in nodeIp2String()
1383 int nodeUpdateAddressIfNeeded(clusterNode *node, clusterLink *link, int port) { in nodeUpdateAddressIfNeeded()
1541 int clusterProcessPacket(clusterLink *link) { in clusterProcessPacket()
1987 void handleLinkIOError(clusterLink *link) { in handleLinkIOError()
1995 clusterLink *link = (clusterLink*) privdata; in clusterWriteHandler()
2019 clusterLink *link = (clusterLink*) privdata; in clusterReadHandler()
2083 void clusterSendMessage(clusterLink *link, unsigned char *msg, size_t msglen) { in clusterSendMessage()
2175 void clusterSendPing(clusterLink *link, int type) { in clusterSendPing()
2333 void clusterSendPublish(clusterLink *link, robj *channel, robj *message) { in clusterSendPublish()
2391 void clusterSendUpdate(clusterLink *link, clusterNode *node) { in clusterSendUpdate()
3100 clusterLink *link; in clusterCron()