Home
last modified time | relevance | path

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

/f-stack/app/redis-5.0.5/src/
H A Drax.h208 uint64_t raxSize(rax *rax);
H A Dt_stream.c1676 uint64_t retval = raxSize(consumer->pel); in streamDelConsumer()
1967 addReplyLongLong(c,raxSize(group->pel)); in xpendingCommand()
1969 if (raxSize(group->pel) == 0) { in xpendingCommand()
1996 if (raxSize(consumer->pel) == 0) continue; in xpendingCommand()
1999 addReplyBulkLongLong(c,raxSize(consumer->pel)); in xpendingCommand()
2473 addReplyMultiBulkLen(c,raxSize(cg->consumers)); in xinfoCommand()
2487 addReplyLongLong(c,raxSize(consumer->pel)); in xinfoCommand()
2499 addReplyMultiBulkLen(c,raxSize(s->cgroups)); in xinfoCommand()
2509 addReplyLongLong(c,raxSize(cg->consumers)); in xinfoCommand()
2511 addReplyLongLong(c,raxSize(cg->pel)); in xinfoCommand()
[all …]
H A Drdb.c685 if ((n = rdbSaveLen(rdb,raxSize(pel))) == -1) return -1; in rdbSaveStreamPEL()
721 if ((n = rdbSaveLen(rdb,raxSize(cg->consumers))) == -1) return -1; in rdbSaveStreamConsumers()
898 if ((n = rdbSaveLen(rdb,raxSize(rax))) == -1) return -1; in rdbSaveObject()
932 size_t num_cgroups = s->cgroups ? raxSize(s->cgroups) : 0; in rdbSaveObject()
H A Ddefrag.c747 if (raxSize(s->rax) > server.active_defrag_max_scan_fields) { in defragStream()
H A Dobject.c909 asize += sizeof(streamNACK)*raxSize(cg->pel); in objectComputeSize()
H A Drax.c1816 uint64_t raxSize(rax *rax) { in raxSize() function
H A Dmodule.c4339 return (raxSize(Timers) > 0) ? next_period : AE_NOMORE; in moduleTimerHandler()
4461 return raxSize(d->rax); in RM_DictSize()