Lines Matching refs:pat
37 pubsubPattern *pat = p; in freePubsubPattern() local
39 decrRefCount(pat->pattern); in freePubsubPattern()
40 zfree(pat); in freePubsubPattern()
132 pubsubPattern *pat; in pubsubSubscribePattern() local
135 pat = zmalloc(sizeof(*pat)); in pubsubSubscribePattern()
136 pat->pattern = getDecodedObject(pattern); in pubsubSubscribePattern()
137 pat->client = c; in pubsubSubscribePattern()
138 listAddNodeTail(server.pubsub_patterns,pat); in pubsubSubscribePattern()
152 pubsubPattern pat; in pubsubUnsubscribePattern() local
159 pat.client = c; in pubsubUnsubscribePattern()
160 pat.pattern = pattern; in pubsubUnsubscribePattern()
161 ln = listSearchKey(server.pubsub_patterns,&pat); in pubsubUnsubscribePattern()
254 pubsubPattern *pat = ln->value; in pubsubPublishMessage() local
256 if (stringmatchlen((char*)pat->pattern->ptr, in pubsubPublishMessage()
257 sdslen(pat->pattern->ptr), in pubsubPublishMessage()
260 addReply(pat->client,shared.mbulkhdr[4]); in pubsubPublishMessage()
261 addReply(pat->client,shared.pmessagebulk); in pubsubPublishMessage()
262 addReplyBulk(pat->client,pat->pattern); in pubsubPublishMessage()
263 addReplyBulk(pat->client,channel); in pubsubPublishMessage()
264 addReplyBulk(pat->client,message); in pubsubPublishMessage()
332 sds pat = (c->argc == 2) ? NULL : c->argv[2]->ptr; in pubsubCommand() local
343 if (!pat || stringmatchlen(pat, sdslen(pat), in pubsubCommand()