Searched refs:streamLookupCG (Results 1 – 3 of 3) sorted by relevance
106 streamCG *streamLookupCG(stream *s, sds groupname);
1420 (group = streamLookupCG(o->ptr,groupname->ptr)) == NULL) in xreadCommand()1643 streamCG *streamLookupCG(stream *s, sds groupname) { in streamLookupCG() function1754 if ((cg = streamLookupCG(s,grpname)) == NULL && in xgroupCommand()1882 group = streamLookupCG(o->ptr,c->argv[2]->ptr); in xackCommand()1955 (group = streamLookupCG(o->ptr,groupname->ptr)) == NULL) in xpendingCommand()2138 group = streamLookupCG(o->ptr,c->argv[2]->ptr); in xclaimCommand()2465 streamCG *cg = streamLookupCG(s,c->argv[3]->ptr); in xinfoCommand()
405 group = streamLookupCG(s, in handleClientsBlockedOnKeys()