Searched refs:clusterMsg (Results 1 – 2 of 2) sorted by relevance
1542 clusterMsg *hdr = (clusterMsg*) link->rcvbuf; in clusterProcessPacket()2018 clusterMsg *hdr; in clusterReadHandler()2177 clusterMsg *hdr; in clusterSendPing()2224 if (totlen < (int)sizeof(clusterMsg)) totlen = sizeof(clusterMsg); in clusterSendPing()2226 hdr = (clusterMsg*) buf; in clusterSendPing()2335 clusterMsg *hdr = (clusterMsg*) buf; in clusterSendPublish()2381 clusterMsg *hdr = (clusterMsg*) buf; in clusterSendFail()2393 clusterMsg *hdr = (clusterMsg*) buf; in clusterSendUpdate()2426 clusterMsg *hdr = (clusterMsg*) buf; in clusterRequestFailoverAuth()2442 clusterMsg *hdr = (clusterMsg*) buf; in clusterSendFailoverAuth()[all …]
246 } clusterMsg; typedef248 #define CLUSTERMSG_MIN_LEN (sizeof(clusterMsg)-sizeof(union clusterMsgData))