1543     uint32_t totlen = ntohl(hdr->totlen);  in clusterProcessPacket()  local
1548         type, (unsigned long) totlen);  in clusterProcessPacket()
1551     if (totlen < 16) return 1; /* At least signature, version, totlen, count. */  in clusterProcessPacket()
1552     if (totlen > sdslen(link->rcvbuf)) return 1;  in clusterProcessPacket()
1571         if (totlen != explen) return 1;  in clusterProcessPacket()
1576         if (totlen != explen) return 1;  in clusterProcessPacket()
1584         if (totlen != explen) return 1;  in clusterProcessPacket()
1591         if (totlen != explen) return 1;  in clusterProcessPacket()
1596         if (totlen != explen) return 1;  in clusterProcessPacket()
2037                     ntohl(hdr->totlen) < CLUSTERMSG_MIN_LEN)  in clusterReadHandler()
2046             readlen = ntohl(hdr->totlen) - rcvbuflen;  in clusterReadHandler()
2067         if (rcvbuflen >= 8 && rcvbuflen == ntohl(hdr->totlen)) {  in clusterReadHandler()
2117     int totlen = 0;  in clusterBuildMessageHdr()  local
2163         totlen = sizeof(clusterMsg)-sizeof(union clusterMsgData);  in clusterBuildMessageHdr()
2164         totlen += sizeof(clusterMsgDataFail);  in clusterBuildMessageHdr()
2166         totlen = sizeof(clusterMsg)-sizeof(union clusterMsgData);  in clusterBuildMessageHdr()
2167         totlen += sizeof(clusterMsgDataUpdate);  in clusterBuildMessageHdr()
2169     hdr->totlen = htonl(totlen);  in clusterBuildMessageHdr()
2180     int totlen; /* Total packet length. */  in clusterSendPing()  local
2220     totlen = sizeof(clusterMsg)-sizeof(union clusterMsgData);  in clusterSendPing()
2221     totlen += (sizeof(clusterMsgDataGossip)*wanted);  in clusterSendPing()
2224     if (totlen < (int)sizeof(clusterMsg)) totlen = sizeof(clusterMsg);  in clusterSendPing()
2225     buf = zcalloc(totlen);  in clusterSendPing()
2285     totlen = sizeof(clusterMsg)-sizeof(union clusterMsgData);  in clusterSendPing()
2286     totlen += (sizeof(clusterMsgDataGossip)*gossipcount);  in clusterSendPing()
2288     hdr->totlen = htonl(totlen);  in clusterSendPing()
2289     clusterSendMessage(link,buf,totlen);  in clusterSendPing()
2336     uint32_t totlen;  in clusterSendPublish()  local
2345     totlen = sizeof(clusterMsg)-sizeof(union clusterMsgData);  in clusterSendPublish()
2346     totlen += sizeof(clusterMsgDataPublish) - 8 + channel_len + message_len;  in clusterSendPublish()
2350     hdr->totlen = htonl(totlen);  in clusterSendPublish()
2353     if (totlen < sizeof(buf)) {  in clusterSendPublish()
2356         payload = zmalloc(totlen);  in clusterSendPublish()
2365         clusterSendMessage(link,payload,totlen);  in clusterSendPublish()
2367         clusterBroadcastMessage(payload,totlen);  in clusterSendPublish()
2385     clusterBroadcastMessage(buf,ntohl(hdr->totlen));  in clusterSendFail()
2400     clusterSendMessage(link,buf,ntohl(hdr->totlen));  in clusterSendUpdate()
2427     uint32_t totlen;  in clusterRequestFailoverAuth()  local
2434     totlen = sizeof(clusterMsg)-sizeof(union clusterMsgData);  in clusterRequestFailoverAuth()
2435     hdr->totlen = htonl(totlen);  in clusterRequestFailoverAuth()
2436     clusterBroadcastMessage(buf,totlen);  in clusterRequestFailoverAuth()
2443     uint32_t totlen;  in clusterSendFailoverAuth()  local
2447     totlen = sizeof(clusterMsg)-sizeof(union clusterMsgData);  in clusterSendFailoverAuth()
2448     hdr->totlen = htonl(totlen);  in clusterSendFailoverAuth()
2449     clusterSendMessage(node->link,buf,totlen);  in clusterSendFailoverAuth()
2456     uint32_t totlen;  in clusterSendMFStart()  local
2460     totlen = sizeof(clusterMsg)-sizeof(union clusterMsgData);  in clusterSendMFStart()
2461     hdr->totlen = htonl(totlen);  in clusterSendMFStart()
2462     clusterSendMessage(node->link,buf,totlen);  in clusterSendMFStart()