Lines Matching refs:pubsub_channels

52     return dictSize(c->pubsub_channels)+  in clientSubscriptionsCount()
64     if (dictAdd(c->pubsub_channels,channel,NULL) == DICT_OK) {  in pubsubSubscribeChannel()
68         de = dictFind(server.pubsub_channels,channel);  in pubsubSubscribeChannel()
71             dictAdd(server.pubsub_channels,channel,clients);  in pubsubSubscribeChannel()
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()
118         addReplyLongLong(c,dictSize(c->pubsub_channels)+  in pubsubUnsubscribeChannel()
169         addReplyLongLong(c,dictSize(c->pubsub_channels)+  in pubsubUnsubscribePattern()
179     dictIterator *di = dictGetSafeIterator(c->pubsub_channels);  in pubsubUnsubscribeAllChannels()
193         addReplyLongLong(c,dictSize(c->pubsub_channels)+  in pubsubUnsubscribeAllChannels()
218         addReplyLongLong(c,dictSize(c->pubsub_channels)+  in pubsubUnsubscribeAllPatterns()
232     de = dictFind(server.pubsub_channels,channel);  in pubsubPublishMessage()
333         dictIterator *di = dictGetIterator(server.pubsub_channels);  in pubsubCommand()
358             list *l = dictFetchValue(server.pubsub_channels,c->argv[j]);  in pubsubCommand()