1906         robj *channel, *message;  in clusterProcessPacket()  local
1916             channel = createStringObject(  in clusterProcessPacket()
1921             pubsubPublishMessage(channel,message);  in clusterProcessPacket()
1922             decrRefCount(channel);  in clusterProcessPacket()
2333 void clusterSendPublish(clusterLink *link, robj *channel, robj *message) {  in clusterSendPublish()  argument
2339     channel = getDecodedObject(channel);  in clusterSendPublish()
2341     channel_len = sdslen(channel->ptr);  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()
2369     decrRefCount(channel);  in clusterSendPublish()
2410 void clusterPropagatePublish(robj *channel, robj *message) {  in clusterPropagatePublish()  argument
2411     clusterSendPublish(NULL, channel, message);  in clusterPropagatePublish()