Home
last modified time | relevance | path

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

/f-stack/app/redis-5.0.5/src/
H A Dt_stream.c1022 raxStart(&ri,consumer->pel); in streamReplyWithRangeFromConsumerPEL()
1627 cg->pel = raxNew(); in streamCreateCG()
1661 consumer->pel = raxNew(); in streamLookupConsumer()
1676 uint64_t retval = raxSize(consumer->pel); in streamDelConsumer()
1681 raxStart(&ri,consumer->pel); in streamDelConsumer()
1967 addReplyLongLong(c,raxSize(group->pel)); in xpendingCommand()
1969 if (raxSize(group->pel) == 0) { in xpendingCommand()
1976 raxStart(&ri,group->pel); in xpendingCommand()
2019 rax *pel = consumer ? consumer->pel : group->pel; in xpendingCommand() local
2027 raxStart(&ri,pel); in xpendingCommand()
[all …]
H A Dstream.h55 rax *pel; /* Pending entries list. This is a radix tree that member
72 rax *pel; /* Consumer specific pending entries list: all member
H A Ddefrag.c702 raxInsert(ctx->cg->pel, ri->key, ri->key_len, newnack, &prev); in defragStreamConsumerPendingEntry()
720 if (c->pel) { in defragStreamConsumer()
722 *defragged += defragRadixTree(&c->pel, 0, defragStreamConsumerPendingEntry, &pel_ctx); in defragStreamConsumer()
732 if (cg->pel) in defragStreamConsumerGroup()
733 *defragged += defragRadixTree(&cg->pel, 0, NULL, NULL); in defragStreamConsumerGroup()
H A Drdb.c681 ssize_t rdbSaveStreamPEL(rio *rdb, rax *pel, int nacks) { in rdbSaveStreamPEL() argument
685 if ((n = rdbSaveLen(rdb,raxSize(pel))) == -1) return -1; in rdbSaveStreamPEL()
690 raxStart(&ri,pel); in rdbSaveStreamPEL()
744 if ((n = rdbSaveStreamPEL(rdb,consumer->pel,0)) == -1) in rdbSaveStreamConsumers()
955 if ((n = rdbSaveStreamPEL(rdb,cg->pel,1)) == -1) return -1; in rdbSaveObject()
1714 if (!raxInsert(cgroup->pel,rawid,sizeof(rawid),nack,NULL)) in rdbLoadObject()
1739 streamNACK *nack = raxFind(cgroup->pel,rawid,sizeof(rawid)); in rdbLoadObject()
1748 if (!raxInsert(consumer->pel,rawid,sizeof(rawid),nack,NULL)) in rdbLoadObject()
H A Dobject.c908 asize += streamRadixTreeMemoryUsage(cg->pel); in objectComputeSize()
909 asize += sizeof(streamNACK)*raxSize(cg->pel); in objectComputeSize()
920 asize += streamRadixTreeMemoryUsage(consumer->pel); in objectComputeSize()
H A Daof.c1236 raxStart(&ri_pel,consumer->pel); in rewriteStreamObject()