Lines Matching refs:pattern
39 decrRefCount(pat->pattern); in freePubsubPattern()
47 (equalStringObjects(pa->pattern,pb->pattern)); in listMatchPubsubPattern()
127 int pubsubSubscribePattern(client *c, robj *pattern) { in pubsubSubscribePattern() argument
130 if (listSearchKey(c->pubsub_patterns,pattern) == NULL) { in pubsubSubscribePattern()
133 listAddNodeTail(c->pubsub_patterns,pattern); in pubsubSubscribePattern()
134 incrRefCount(pattern); in pubsubSubscribePattern()
136 pat->pattern = getDecodedObject(pattern); in pubsubSubscribePattern()
143 addReplyBulk(c,pattern); in pubsubSubscribePattern()
150 int pubsubUnsubscribePattern(client *c, robj *pattern, int notify) { in pubsubUnsubscribePattern() argument
155 incrRefCount(pattern); /* Protect the object. May be the same we remove */ in pubsubUnsubscribePattern()
156 if ((ln = listSearchKey(c->pubsub_patterns,pattern)) != NULL) { in pubsubUnsubscribePattern()
160 pat.pattern = pattern; in pubsubUnsubscribePattern()
168 addReplyBulk(c,pattern); in pubsubUnsubscribePattern()
172 decrRefCount(pattern); in pubsubUnsubscribePattern()
209 robj *pattern = ln->value; in pubsubUnsubscribeAllPatterns() local
211 count += pubsubUnsubscribePattern(c,pattern,notify); in pubsubUnsubscribeAllPatterns()
256 if (stringmatchlen((char*)pat->pattern->ptr, in pubsubPublishMessage()
257 sdslen(pat->pattern->ptr), in pubsubPublishMessage()
262 addReplyBulk(pat->client,pat->pattern); in pubsubPublishMessage()