Lines Matching refs:message
1906 robj *channel, *message; in clusterProcessPacket() local
1918 message = createStringObject( in clusterProcessPacket()
1921 pubsubPublishMessage(channel,message); in clusterProcessPacket()
1923 decrRefCount(message); in clusterProcessPacket()
2333 void clusterSendPublish(clusterLink *link, robj *channel, robj *message) { in clusterSendPublish() argument
2340 message = getDecodedObject(message); in clusterSendPublish()
2342 message_len = sdslen(message->ptr); in clusterSendPublish()
2362 message->ptr,sdslen(message->ptr)); in clusterSendPublish()
2370 decrRefCount(message); in clusterSendPublish()
2410 void clusterPropagatePublish(robj *channel, robj *message) { in clusterPropagatePublish() argument
2411 clusterSendPublish(NULL, channel, message); in clusterPropagatePublish()