Home
last modified time | relevance | path

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

/f-stack/app/redis-5.0.5/src/
H A Dstream.h67 typedef struct streamConsumer { struct
79 } streamConsumer; typedef
85 streamConsumer *consumer; /* The consumer this message was delivered to
101 …eamID *start, streamID *end, size_t count, int rev, streamCG *group, streamConsumer *consumer, int…
107 streamConsumer *streamLookupConsumer(streamCG *cg, sds name, int create);
109 streamNACK *streamCreateNACK(streamConsumer *consumer);
H A Dt_stream.c45 …rPEL(client *c, stream *s, streamID *start, streamID *end, size_t count, streamConsumer *consumer);
1519 streamConsumer *consumer = NULL; in xreadCommand()
1592 streamNACK *streamCreateNACK(streamConsumer *consumer) { in streamCreateNACK()
1610 void streamFreeConsumer(streamConsumer *sc) { in streamFreeConsumer()
1654 streamConsumer *streamLookupConsumer(streamCG *cg, sds name, int create) { in streamLookupConsumer()
1655 streamConsumer *consumer = raxFind(cg->consumers,(unsigned char*)name, in streamLookupConsumer()
1673 streamConsumer *consumer = streamLookupConsumer(cg,name,0); in streamDelConsumer()
1995 streamConsumer *consumer = ri.data; in xpendingCommand()
2008 streamConsumer *consumer = consumername ? in xpendingCommand()
2225 streamConsumer *consumer = streamLookupConsumer(group,c->argv[3]->ptr,1); in xclaimCommand()
[all …]
H A Dblocked.c425 streamConsumer *consumer = NULL; in handleClientsBlockedOnKeys()
H A Ddefrag.c690 streamConsumer *c;
710 streamConsumer *c = ri->data; in defragStreamConsumer()
H A Daof.c1139 …ntry(rio *r, robj *key, const char *groupname, size_t groupname_len, streamConsumer *consumer, uns… in rioWriteStreamPendingEntry()
1232 streamConsumer *consumer = ri_cons.data; in rewriteStreamObject()
H A Drdb.c729 streamConsumer *consumer = ri.data; in rdbSaveStreamConsumers()
1728 streamConsumer *consumer = streamLookupConsumer(cgroup,cname, in rdbLoadObject()
H A Dobject.c917 streamConsumer *consumer = cri.data; in objectComputeSize()