Searched refs:raxNext (Results 1 – 9 of 9) sorted by relevance
201 int raxNext(raxIterator *it);
189 if (raxNext(&ri)) { in streamAppendItem()382 while(s->length > maxlen && raxNext(&ri)) { in streamTrimByLength()539 if (!si->rev && !raxNext(&si->ri)) return 0; in streamIteratorGetID()1024 while(raxNext(&ri) && (!count || arraylen < count)) { in streamReplyWithRangeFromConsumerPEL()1683 while(raxNext(&ri)) { in streamDelConsumer()1978 raxNext(&ri); in xpendingCommand()1984 raxNext(&ri); in xpendingCommand()1994 while(raxNext(&ri)) { in xpendingCommand()2032 while(count && raxNext(&ri) && memcmp(ri.key,endkey,ri.key_len) <= 0) { in xpendingCommand()2478 while(raxNext(&ri)) { in xinfoCommand()[all …]
880 while(samples < sample_size && raxNext(&ri)) { in objectComputeSize()893 raxNext(&ri); in objectComputeSize()905 while(raxNext(&ri)) { in objectComputeSize()916 while(raxNext(&cri)) { in objectComputeSize()
1215 while(raxNext(&ri)) { in rewriteStreamObject()1231 while(raxNext(&ri_cons)) { in rewriteStreamObject()1238 while(raxNext(&ri_pel)) { in rewriteStreamObject()
692 while(raxNext(&ri)) { in rdbSaveStreamPEL()728 while(raxNext(&ri)) { in rdbSaveStreamConsumers()907 while (raxNext(&ri)) { in rdbSaveObject()940 while(raxNext(&ri)) { in rdbSaveObject()
637 while (raxNext(&ri)) { in scanLaterStraemListpacks()675 while (raxNext(&ri)) { in defragRadixTree()
1516 while(count-- && raxNext(&iter)) { in getKeysInSlot()1536 raxNext(&iter); in delKeysInSlot()
4315 if (!raxNext(&ri)) break; in moduleTimerHandler()4371 raxNext(&ri); in RM_CreateTimer()4607 if (!raxNext(&di->ri)) return NULL; in RM_DictNextC()
1693 int raxNext(raxIterator *it) { in raxNext() function