Home
last modified time | relevance | path

Searched refs:pubsub_channels (Results 1 – 5 of 5) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Dpubsub.c52 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 Dnetworking.c153 c->pubsub_channels = dictCreate(&objectKeyPointerValueDictType,NULL); in createClient()
895 dictRelease(c->pubsub_channels); in freeClient()
1685 (int) dictSize(client->pubsub_channels), in catClientInfoString()
H A Dserver.h764 dict *pubsub_channels; /* channels a client is interested in (SUBSCRIBE) */ member
1228 dict *pubsub_channels; /* Map channels to list of subscribed clients */ member
H A Dserver.c2095 server.pubsub_channels = dictCreate(&keylistDictType,NULL); in initServer()
3481 dictSize(server.pubsub_channels), in genRedisInfoString()
H A Dcluster.c2028 if (dictSize(server.pubsub_channels) || in clusterProcessPacket()