Home
last modified time | relevance | path

Searched refs:streamCG (Results 1 – 7 of 7) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Dstream.h51 typedef struct streamCG { struct
64 } streamCG; typedef
101 …t *c, stream *s, streamID *start, streamID *end, size_t count, int rev, streamCG *group, streamCon…
106 streamCG *streamLookupCG(stream *s, sds groupname);
107 streamConsumer *streamLookupConsumer(streamCG *cg, sds name, int create);
108 streamCG *streamCreateCG(stream *s, char *name, size_t namelen, streamID *id);
H A Dt_stream.c43 void streamFreeCG(streamCG *cg);
1337 streamCG **groups = NULL; in xreadCommand()
1414 streamCG *group = NULL; in xreadCommand()
1626 streamCG *cg = zmalloc(sizeof(*cg)); in streamCreateCG()
1635 void streamFreeCG(streamCG *cg) { in streamFreeCG()
1643 streamCG *streamLookupCG(stream *s, sds groupname) { in streamLookupCG()
1716 streamCG *cg = NULL; in xgroupCommand()
1878 streamCG *group = NULL; in xackCommand()
1951 streamCG *group; in xpendingCommand()
2128 streamCG *group = NULL; in xclaimCommand()
[all …]
H A Ddefrag.c689 streamCG *cg;
711 streamCG *cg = privdata; in defragStreamConsumer()
728 streamCG *cg = ri->data; in defragStreamConsumerGroup()
H A Dblocked.c403 streamCG *group = NULL; in handleClientsBlockedOnKeys()
H A Drdb.c717 size_t rdbSaveStreamConsumers(rio *rdb, streamCG *cg) { in rdbSaveStreamConsumers()
941 streamCG *cg = ri.data; in rdbSaveObject()
1696 streamCG *cgroup = streamCreateCG(s,cgname,sdslen(cgname),&cg_id); in rdbLoadObject()
H A Dobject.c906 streamCG *cg = ri.data; in objectComputeSize()
H A Daof.c1216 streamCG *group = ri.data; in rewriteStreamObject()