Searched refs:channel (Results 1 – 6 of 6) sorted by relevance
| /redis-3.2.3/src/ |
| H A D | pubsub.c | 66 incrRefCount(channel); in pubsubSubscribeChannel()
72 incrRefCount(channel); in pubsubSubscribeChannel()
81 addReplyBulk(c,channel); in pubsubSubscribeChannel()
117 addReplyBulk(c,channel); in pubsubUnsubscribeChannel()
184 robj *channel = dictGetKey(de); in pubsubUnsubscribeAllChannels() local
232 de = dictFind(server.pubsub_channels,channel); in pubsubPublishMessage()
244 addReplyBulk(c,channel); in pubsubPublishMessage()
252 channel = getDecodedObject(channel); in pubsubPublishMessage()
268 decrRefCount(channel); in pubsubPublishMessage()
341 sds channel = cobj->ptr; in pubsubCommand() local
[all …]
|
| H A D | cluster.c | 1906 robj *channel, *message; in clusterProcessPacket() local
1916 channel = createStringObject( in clusterProcessPacket()
1921 pubsubPublishMessage(channel,message); in clusterProcessPacket()
1922 decrRefCount(channel); in clusterProcessPacket()
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
[all …]
|
| H A D | server.h | 1384 int pubsubPublishMessage(robj *channel, robj *message);
1444 void clusterPropagatePublish(robj *channel, robj *message);
|
| H A D | sentinel.c | 586 robj *channel, *payload; in sentinelEvent() local
621 channel = createStringObject(type,strlen(type)); in sentinelEvent()
623 pubsubPublishMessage(channel,payload); in sentinelEvent()
624 decrRefCount(channel); in sentinelEvent()
|
| /redis-3.2.3/tests/unit/ |
| H A D | protocol.tcl | 106 set fd [r channel]
|
| H A D | keyspace.tcl | 61 set fd [r channel]
|