Searched refs:streamLookupConsumer (Results 1 – 4 of 4) sorted by relevance
| /f-stack/app/redis-5.0.5/src/ |
| H A D | stream.h | 107 streamConsumer *streamLookupConsumer(streamCG *cg, sds name, int create);
|
| H A D | t_stream.c | 1520 if (groups) consumer = streamLookupConsumer(groups[i], in xreadCommand()
1654 streamConsumer *streamLookupConsumer(streamCG *cg, sds name, int create) { in streamLookupConsumer() function
1673 streamConsumer *consumer = streamLookupConsumer(cg,name,0); in streamDelConsumer()
2009 streamLookupConsumer(group,consumername->ptr,0): in xpendingCommand()
2225 streamConsumer *consumer = streamLookupConsumer(group,c->argv[3]->ptr,1); in xclaimCommand()
|
| H A D | blocked.c | 429 consumer = streamLookupConsumer(group, in handleClientsBlockedOnKeys()
|
| H A D | rdb.c | 1728 streamConsumer *consumer = streamLookupConsumer(cgroup,cname, in rdbLoadObject()
|