Home
last modified time | relevance | path

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

/f-stack/app/redis-5.0.5/src/
H A Dpubsub.c53 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 Dnetworking.c154 c->pubsub_patterns = listCreate(); in createClient()
157 listSetFreeMethod(c->pubsub_patterns,decrRefCountVoid); in createClient()
158 listSetMatchMethod(c->pubsub_patterns,listMatchObjects); in createClient()
896 listRelease(c->pubsub_patterns); in freeClient()
1686 (int) listLength(client->pubsub_patterns), in catClientInfoString()
H A Dserver.c2096 server.pubsub_patterns = listCreate(); in initServer()
2097 listSetFreeMethod(server.pubsub_patterns,freePubsubPattern); in initServer()
2098 listSetMatchMethod(server.pubsub_patterns,listMatchPubsubPattern); in initServer()
3482 listLength(server.pubsub_patterns), in genRedisInfoString()
H A Dserver.h765 list *pubsub_patterns; /* patterns a client is interested in (SUBSCRIBE) */ member
1229 list *pubsub_patterns; /* A list of pubsub_patterns */ member
H A Dcluster.c2029 listLength(server.pubsub_patterns)) in clusterProcessPacket()