Home
last modified time | relevance | path

Searched refs:streamNACK (Results 1 – 6 of 6) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Dstream.h82 typedef struct streamNACK { struct
87 } streamNACK; argument
109 streamNACK *streamCreateNACK(streamConsumer *consumer);
H A Dt_stream.c44 void streamFreeNACK(streamNACK *na);
794 …opagateXCLAIM(client *c, robj *key, streamCG *group, robj *groupname, robj *id, streamNACK *nack) { in streamPropagateXCLAIM()
957 streamNACK *nack = streamCreateNACK(consumer); in streamReplyWithRange()
1041 streamNACK *nack = ri.data; in streamReplyWithRangeFromConsumerPEL()
1592 streamNACK *streamCreateNACK(streamConsumer *consumer) { in streamCreateNACK()
1593 streamNACK *nack = zmalloc(sizeof(*nack)); in streamCreateNACK()
1601 void streamFreeNACK(streamNACK *na) { in streamFreeNACK()
1684 streamNACK *nack = ri.data; in streamDelConsumer()
1901 streamNACK *nack = raxFind(group->pel,buf,sizeof(buf)); in xackCommand()
2033 streamNACK *nack = ri.data; in xpendingCommand()
[all …]
H A Drdb.c699 streamNACK *nack = ri.data; in rdbSaveStreamPEL()
1711 streamNACK *nack = streamCreateNACK(NULL); in rdbLoadObject()
1739 streamNACK *nack = raxFind(cgroup->pel,rawid,sizeof(rawid)); in rdbLoadObject()
H A Daof.c1139 …roupname, size_t groupname_len, streamConsumer *consumer, unsigned char *rawid, streamNACK *nack) { in rioWriteStreamPendingEntry()
1239 streamNACK *nack = ri_pel.data; in rewriteStreamObject()
H A Ddefrag.c696 streamNACK *nack = ri->data, *newnack; in defragStreamConsumerPendingEntry()
H A Dobject.c909 asize += sizeof(streamNACK)*raxSize(cg->pel); in objectComputeSize()