Lines Matching refs:pubsub_patterns

53            listLength(c->pubsub_patterns);  in clientSubscriptionsCount()
119                        listLength(c->pubsub_patterns));  in pubsubUnsubscribeChannel()
130     if (listSearchKey(c->pubsub_patterns,pattern) == NULL) {  in pubsubSubscribePattern()
133         listAddNodeTail(c->pubsub_patterns,pattern);  in pubsubSubscribePattern()
138         listAddNodeTail(server.pubsub_patterns,pat);  in pubsubSubscribePattern()
156     if ((ln = listSearchKey(c->pubsub_patterns,pattern)) != NULL) {  in pubsubUnsubscribePattern()
158         listDelNode(c->pubsub_patterns,ln);  in pubsubUnsubscribePattern()
161         ln = listSearchKey(server.pubsub_patterns,&pat);  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()
219                        listLength(c->pubsub_patterns));  in pubsubUnsubscribeAllPatterns()
250     if (listLength(server.pubsub_patterns)) {  in pubsubPublishMessage()
251         listRewind(server.pubsub_patterns,&li);  in pubsubPublishMessage()
373         addReplyLongLong(c,listLength(server.pubsub_patterns));  in pubsubCommand()