Searched refs:pubsub_channels (Results 1 – 5 of 5) sorted by relevance
| /redis-3.2.3/src/ |
| H A D | pubsub.c | 52 return dictSize(c->pubsub_channels)+ in clientSubscriptionsCount()
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()
193 addReplyLongLong(c,dictSize(c->pubsub_channels)+ in pubsubUnsubscribeAllChannels()
218 addReplyLongLong(c,dictSize(c->pubsub_channels)+ in pubsubUnsubscribeAllPatterns()
[all …]
|
| H A D | networking.c | 123 c->pubsub_channels = dictCreate(&setDictType,NULL); in createClient()
827 dictRelease(c->pubsub_channels); in freeClient()
1458 (int) dictSize(client->pubsub_channels), in catClientInfoString()
|
| H A D | server.h | 609 dict *pubsub_channels; /* channels a client is interested in (SUBSCRIBE) */ member
938 dict *pubsub_channels; /* Map channels to list of subscribed clients */ member
|
| H A D | server.c | 1917 server.pubsub_channels = dictCreate(&keylistDictType,NULL); in initServer()
3114 dictSize(server.pubsub_channels), in genRedisInfoString()
|
| H A D | cluster.c | 1911 if (dictSize(server.pubsub_channels) || in clusterProcessPacket()
|