58 int pubsubSubscribeChannel(client *c, robj *channel) {  in pubsubSubscribeChannel()  argument
64     if (dictAdd(c->pubsub_channels,channel,NULL) == DICT_OK) {  in pubsubSubscribeChannel()
66         incrRefCount(channel);  in pubsubSubscribeChannel()
68         de = dictFind(server.pubsub_channels,channel);  in pubsubSubscribeChannel()
71             dictAdd(server.pubsub_channels,channel,clients);  in pubsubSubscribeChannel()
72             incrRefCount(channel);  in pubsubSubscribeChannel()
81     addReplyBulk(c,channel);  in pubsubSubscribeChannel()
88 int pubsubUnsubscribeChannel(client *c, robj *channel, int notify) {  in pubsubUnsubscribeChannel()  argument
95     incrRefCount(channel); /* channel may be just a pointer to the same object  in pubsubUnsubscribeChannel()
97     if (dictDelete(c->pubsub_channels,channel) == DICT_OK) {  in pubsubUnsubscribeChannel()
100         de = dictFind(server.pubsub_channels,channel);  in pubsubUnsubscribeChannel()
110             dictDelete(server.pubsub_channels,channel);  in pubsubUnsubscribeChannel()
117         addReplyBulk(c,channel);  in pubsubUnsubscribeChannel()
122     decrRefCount(channel); /* it is finally safe to release it */  in pubsubUnsubscribeChannel()
184         robj *channel = dictGetKey(de);  in pubsubUnsubscribeAllChannels()  local
186         count += pubsubUnsubscribeChannel(c,channel,notify);  in pubsubUnsubscribeAllChannels()
225 int pubsubPublishMessage(robj *channel, robj *message) {  in pubsubPublishMessage()  argument
232     de = dictFind(server.pubsub_channels,channel);  in pubsubPublishMessage()
244             addReplyBulk(c,channel);  in pubsubPublishMessage()
252         channel = getDecodedObject(channel);  in pubsubPublishMessage()
258                                 (char*)channel->ptr,  in pubsubPublishMessage()
259                                 sdslen(channel->ptr),0)) {  in pubsubPublishMessage()
263                 addReplyBulk(pat->client,channel);  in pubsubPublishMessage()
268         decrRefCount(channel);  in pubsubPublishMessage()
341             sds channel = cobj->ptr;  in pubsubCommand()  local
344                                        channel, sdslen(channel),0))  in pubsubCommand()