Searched refs:pubsub_patterns (Results 1 – 5 of 5) sorted by relevance
| /redis-3.2.3/src/ |
| H A D | pubsub.c | 53 listLength(c->pubsub_patterns); in clientSubscriptionsCount()
119 listLength(c->pubsub_patterns)); in pubsubUnsubscribeChannel()
133 listAddNodeTail(c->pubsub_patterns,pattern); in pubsubSubscribePattern()
138 listAddNodeTail(server.pubsub_patterns,pat); in pubsubSubscribePattern()
158 listDelNode(c->pubsub_patterns,ln); in pubsubUnsubscribePattern()
162 listDelNode(server.pubsub_patterns,ln); in pubsubUnsubscribePattern()
170 listLength(c->pubsub_patterns)); in pubsubUnsubscribePattern()
194 listLength(c->pubsub_patterns)); in pubsubUnsubscribeAllChannels()
207 listRewind(c->pubsub_patterns,&li); in pubsubUnsubscribeAllPatterns()
250 if (listLength(server.pubsub_patterns)) { in pubsubPublishMessage()
[all …]
|
| H A D | networking.c | 124 c->pubsub_patterns = listCreate(); in createClient()
126 listSetFreeMethod(c->pubsub_patterns,decrRefCountVoid); in createClient()
127 listSetMatchMethod(c->pubsub_patterns,listMatchObjects); in createClient()
828 listRelease(c->pubsub_patterns); in freeClient()
1459 (int) listLength(client->pubsub_patterns), in catClientInfoString()
|
| H A D | server.h | 610 list *pubsub_patterns; /* patterns a client is interested in (SUBSCRIBE) */ member
939 list *pubsub_patterns; /* A list of pubsub_patterns */ member
|
| H A D | server.c | 1918 server.pubsub_patterns = listCreate(); in initServer()
1919 listSetFreeMethod(server.pubsub_patterns,freePubsubPattern); in initServer()
1920 listSetMatchMethod(server.pubsub_patterns,listMatchPubsubPattern); in initServer()
3115 listLength(server.pubsub_patterns), in genRedisInfoString()
|
| H A D | cluster.c | 1912 listLength(server.pubsub_patterns)) in clusterProcessPacket()
|