Lines Matching refs:server
68 de = dictFind(server.pubsub_channels,channel); in pubsubSubscribeChannel()
71 dictAdd(server.pubsub_channels,channel,clients); in pubsubSubscribeChannel()
100 de = dictFind(server.pubsub_channels,channel); in pubsubUnsubscribeChannel()
110 dictDelete(server.pubsub_channels,channel); in pubsubUnsubscribeChannel()
138 listAddNodeTail(server.pubsub_patterns,pat); in pubsubSubscribePattern()
161 ln = listSearchKey(server.pubsub_patterns,&pat); in pubsubUnsubscribePattern()
162 listDelNode(server.pubsub_patterns,ln); in pubsubUnsubscribePattern()
232 de = dictFind(server.pubsub_channels,channel); in pubsubPublishMessage()
250 if (listLength(server.pubsub_patterns)) { in pubsubPublishMessage()
251 listRewind(server.pubsub_patterns,&li); in pubsubPublishMessage()
319 if (server.cluster_enabled) in publishCommand()
341 dictIterator *di = dictGetIterator(server.pubsub_channels); in pubsubCommand()
366 list *l = dictFetchValue(server.pubsub_channels,c->argv[j]); in pubsubCommand()
373 addReplyLongLong(c,listLength(server.pubsub_patterns)); in pubsubCommand()