56 void clusterSendFailoverAuthIfNeeded(clusterNode *node, clusterMsg *request);
1293 void clusterProcessGossipSection(clusterMsg *hdr, clusterLink *link) {  in clusterProcessGossipSection()
1542     clusterMsg *hdr = (clusterMsg*) link->rcvbuf;  in clusterProcessPacket()
1569         explen = sizeof(clusterMsg)-sizeof(union clusterMsgData);  in clusterProcessPacket()
1573         uint32_t explen = sizeof(clusterMsg)-sizeof(union clusterMsgData);  in clusterProcessPacket()
1578         uint32_t explen = sizeof(clusterMsg)-sizeof(union clusterMsgData);  in clusterProcessPacket()
1589         uint32_t explen = sizeof(clusterMsg)-sizeof(union clusterMsgData);  in clusterProcessPacket()
1593         uint32_t explen = sizeof(clusterMsg)-sizeof(union clusterMsgData);  in clusterProcessPacket()
2016     char buf[sizeof(clusterMsg)];  in clusterReadHandler()
2018     clusterMsg *hdr;  in clusterReadHandler()
2032             hdr = (clusterMsg*) link->rcvbuf;  in clusterReadHandler()
2062             hdr = (clusterMsg*) link->rcvbuf;  in clusterReadHandler()
2116 void clusterBuildMessageHdr(clusterMsg *hdr, int type) {  in clusterBuildMessageHdr()
2163         totlen = sizeof(clusterMsg)-sizeof(union clusterMsgData);  in clusterBuildMessageHdr()
2166         totlen = sizeof(clusterMsg)-sizeof(union clusterMsgData);  in clusterBuildMessageHdr()
2177     clusterMsg *hdr;  in clusterSendPing()
2220     totlen = sizeof(clusterMsg)-sizeof(union clusterMsgData);  in clusterSendPing()
2224     if (totlen < (int)sizeof(clusterMsg)) totlen = sizeof(clusterMsg);  in clusterSendPing()
2226     hdr = (clusterMsg*) buf;  in clusterSendPing()
2285     totlen = sizeof(clusterMsg)-sizeof(union clusterMsgData);  in clusterSendPing()
2334     unsigned char buf[sizeof(clusterMsg)], *payload;  in clusterSendPublish()
2335     clusterMsg *hdr = (clusterMsg*) buf;  in clusterSendPublish()
2345     totlen = sizeof(clusterMsg)-sizeof(union clusterMsgData);  in clusterSendPublish()
2358         hdr = (clusterMsg*) payload;  in clusterSendPublish()
2380     unsigned char buf[sizeof(clusterMsg)];  in clusterSendFail()
2381     clusterMsg *hdr = (clusterMsg*) buf;  in clusterSendFail()
2392     unsigned char buf[sizeof(clusterMsg)];  in clusterSendUpdate()
2393     clusterMsg *hdr = (clusterMsg*) buf;  in clusterSendUpdate()
2425     unsigned char buf[sizeof(clusterMsg)];  in clusterRequestFailoverAuth()
2426     clusterMsg *hdr = (clusterMsg*) buf;  in clusterRequestFailoverAuth()
2434     totlen = sizeof(clusterMsg)-sizeof(union clusterMsgData);  in clusterRequestFailoverAuth()
2441     unsigned char buf[sizeof(clusterMsg)];  in clusterSendFailoverAuth()
2442     clusterMsg *hdr = (clusterMsg*) buf;  in clusterSendFailoverAuth()
2447     totlen = sizeof(clusterMsg)-sizeof(union clusterMsgData);  in clusterSendFailoverAuth()
2454     unsigned char buf[sizeof(clusterMsg)];  in clusterSendMFStart()
2455     clusterMsg *hdr = (clusterMsg*) buf;  in clusterSendMFStart()
2460     totlen = sizeof(clusterMsg)-sizeof(union clusterMsgData);  in clusterSendMFStart()
2466 void clusterSendFailoverAuthIfNeeded(clusterNode *node, clusterMsg *request) {  in clusterSendFailoverAuthIfNeeded()