Searched refs:streamLookupCG (Results 1 – 9 of 9) sorted by relevance
| /dports/databases/redis5/redis-5.0.14/src/ |
| H A D | stream.h | 112 streamCG *streamLookupCG(stream *s, sds groupname);
|
| H A D | t_stream.c | 1507 (group = streamLookupCG(o->ptr,groupname->ptr)) == NULL) in xreadCommand()
1734 streamCG *streamLookupCG(stream *s, sds groupname) { in streamLookupCG() function
1848 if ((cg = streamLookupCG(s,grpname)) == NULL && in xgroupCommand()
1972 group = streamLookupCG(o->ptr,c->argv[2]->ptr); in xackCommand()
2045 (group = streamLookupCG(o->ptr,groupname->ptr)) == NULL) in xpendingCommand()
2231 group = streamLookupCG(o->ptr,c->argv[2]->ptr); in xclaimCommand()
2560 streamCG *cg = streamLookupCG(s,c->argv[3]->ptr); in xinfoCommand()
|
| H A D | blocked.c | 429 group = streamLookupCG(s, in handleClientsBlockedOnKeys()
|
| /dports/databases/redis6/redis-6.0.16/src/ |
| H A D | stream.h | 112 streamCG *streamLookupCG(stream *s, sds groupname);
|
| H A D | t_stream.c | 1497 (group = streamLookupCG(o->ptr,groupname->ptr)) == NULL) in xreadCommand()
1727 streamCG *streamLookupCG(stream *s, sds groupname) { in streamLookupCG() function
1841 if ((cg = streamLookupCG(s,grpname)) == NULL && in xgroupCommand()
1968 group = streamLookupCG(o->ptr,c->argv[2]->ptr); in xackCommand()
2051 (group = streamLookupCG(o->ptr,groupname->ptr)) == NULL) in xpendingCommand()
2237 group = streamLookupCG(o->ptr,c->argv[2]->ptr); in xclaimCommand()
2754 streamCG *cg = streamLookupCG(s,c->argv[3]->ptr); in xinfoCommand()
|
| H A D | blocked.c | 358 group = streamLookupCG(s, in serveClientsBlockedOnStreamKey()
|
| /dports/databases/redis-devel/redis-0e5b813/src/ |
| H A D | stream.h | 117 streamCG *streamLookupCG(stream *s, sds groupname);
|
| H A D | t_stream.c | 2082 (group = streamLookupCG(o->ptr,groupname->ptr)) == NULL) in xreadCommand()
2321 streamCG *streamLookupCG(stream *s, sds groupname) { in streamLookupCG() function
2433 if ((cg = streamLookupCG(s,grpname)) == NULL && in xgroupCommand()
2584 group = streamLookupCG(o->ptr,c->argv[2]->ptr); in xackCommand()
2702 (group = streamLookupCG(o->ptr,groupname->ptr)) == NULL) in xpendingCommand()
2889 group = streamLookupCG(o->ptr,c->argv[2]->ptr); in xclaimCommand()
3134 group = streamLookupCG(o->ptr,c->argv[2]->ptr); in xautoclaimCommand()
3565 streamCG *cg = streamLookupCG(s,c->argv[3]->ptr); in xinfoCommand()
|
| H A D | blocked.c | 415 group = streamLookupCG(s, in serveClientsBlockedOnStreamKey()
|