1582                 ntohl(hdr->data.publish.msg.channel_len) +  in clusterProcessPacket()
1583                 ntohl(hdr->data.publish.msg.message_len);  in clusterProcessPacket()
1914             channel_len = ntohl(hdr->data.publish.msg.channel_len);  in clusterProcessPacket()
1915             message_len = ntohl(hdr->data.publish.msg.message_len);  in clusterProcessPacket()
1917                         (char*)hdr->data.publish.msg.bulk_data,channel_len);  in clusterProcessPacket()
1919                         (char*)hdr->data.publish.msg.bulk_data+channel_len,  in clusterProcessPacket()
2083 void clusterSendMessage(clusterLink *link, unsigned char *msg, size_t msglen) {  in clusterSendMessage()  argument
2088     link->sndbuf = sdscatlen(link->sndbuf, msg, msglen);  in clusterSendMessage()
2348     hdr->data.publish.msg.channel_len = htonl(channel_len);  in clusterSendPublish()
2349     hdr->data.publish.msg.message_len = htonl(message_len);  in clusterSendPublish()
2360     memcpy(hdr->data.publish.msg.bulk_data,channel->ptr,sdslen(channel->ptr));  in clusterSendPublish()
2361     memcpy(hdr->data.publish.msg.bulk_data+sdslen(channel->ptr),  in clusterSendPublish()
2619     char *msg;  in clusterLogCantFailover()  local
2639         msg = "Disconnected from master for longer than allowed. "  in clusterLogCantFailover()
2644         msg = "Waiting the delay before I can start a new failover.";  in clusterLogCantFailover()
2647         msg = "Failover attempt expired.";  in clusterLogCantFailover()
2650         msg = "Waiting for votes, but majority still not reached.";  in clusterLogCantFailover()
2653         msg = "Unknown reason code.";  in clusterLogCantFailover()
2657     serverLog(LL_WARNING,"Currently unable to failover: %s", msg);  in clusterLogCantFailover()