Lines Matching refs:zl
695 unsigned int zzlLength(unsigned char *zl) { in zzlLength() argument
696 return ziplistLen(zl)/2; in zzlLength()
701 void zzlNext(unsigned char *zl, unsigned char **eptr, unsigned char **sptr) { in zzlNext() argument
705 _eptr = ziplistNext(zl,*sptr); in zzlNext()
707 _sptr = ziplistNext(zl,_eptr); in zzlNext()
720 void zzlPrev(unsigned char *zl, unsigned char **eptr, unsigned char **sptr) { in zzlPrev() argument
724 _sptr = ziplistPrev(zl,*eptr); in zzlPrev()
726 _eptr = ziplistPrev(zl,_sptr); in zzlPrev()
739 int zzlIsInRange(unsigned char *zl, zrangespec *range) { in zzlIsInRange() argument
748 p = ziplistIndex(zl,-1); /* Last score. */ in zzlIsInRange()
754 p = ziplistIndex(zl,1); /* First score. */ in zzlIsInRange()
765 unsigned char *zzlFirstInRange(unsigned char *zl, zrangespec *range) { in zzlFirstInRange() argument
766 unsigned char *eptr = ziplistIndex(zl,0), *sptr; in zzlFirstInRange()
770 if (!zzlIsInRange(zl,range)) return NULL; in zzlFirstInRange()
773 sptr = ziplistNext(zl,eptr); in zzlFirstInRange()
785 eptr = ziplistNext(zl,sptr); in zzlFirstInRange()
793 unsigned char *zzlLastInRange(unsigned char *zl, zrangespec *range) { in zzlLastInRange() argument
794 unsigned char *eptr = ziplistIndex(zl,-2), *sptr; in zzlLastInRange()
798 if (!zzlIsInRange(zl,range)) return NULL; in zzlLastInRange()
801 sptr = ziplistNext(zl,eptr); in zzlLastInRange()
814 sptr = ziplistPrev(zl,eptr); in zzlLastInRange()
816 serverAssert((eptr = ziplistPrev(zl,sptr)) != NULL); in zzlLastInRange()
840 int zzlIsInLexRange(unsigned char *zl, zlexrangespec *range) { in zzlIsInLexRange() argument
849 p = ziplistIndex(zl,-2); /* Last element. */ in zzlIsInLexRange()
854 p = ziplistIndex(zl,0); /* First element. */ in zzlIsInLexRange()
864 unsigned char *zzlFirstInLexRange(unsigned char *zl, zlexrangespec *range) { in zzlFirstInLexRange() argument
865 unsigned char *eptr = ziplistIndex(zl,0), *sptr; in zzlFirstInLexRange()
868 if (!zzlIsInLexRange(zl,range)) return NULL; in zzlFirstInLexRange()
879 sptr = ziplistNext(zl,eptr); /* This element score. Skip it. */ in zzlFirstInLexRange()
881 eptr = ziplistNext(zl,sptr); /* Next element. */ in zzlFirstInLexRange()
889 unsigned char *zzlLastInLexRange(unsigned char *zl, zlexrangespec *range) { in zzlLastInLexRange() argument
890 unsigned char *eptr = ziplistIndex(zl,-2), *sptr; in zzlLastInLexRange()
893 if (!zzlIsInLexRange(zl,range)) return NULL; in zzlLastInLexRange()
905 sptr = ziplistPrev(zl,eptr); in zzlLastInLexRange()
907 serverAssert((eptr = ziplistPrev(zl,sptr)) != NULL); in zzlLastInLexRange()
915 unsigned char *zzlFind(unsigned char *zl, robj *ele, double *score) { in zzlFind() argument
916 unsigned char *eptr = ziplistIndex(zl,0), *sptr; in zzlFind()
920 sptr = ziplistNext(zl,eptr); in zzlFind()
931 eptr = ziplistNext(zl,sptr); in zzlFind()
940 unsigned char *zzlDelete(unsigned char *zl, unsigned char *eptr) { in zzlDelete() argument
944 zl = ziplistDelete(zl,&p); in zzlDelete()
945 zl = ziplistDelete(zl,&p); in zzlDelete()
946 return zl; in zzlDelete()
949 unsigned char *zzlInsertAt(unsigned char *zl, unsigned char *eptr, robj *ele, double score) { in zzlInsertAt() argument
958 zl = ziplistPush(zl,ele->ptr,sdslen(ele->ptr),ZIPLIST_TAIL); in zzlInsertAt()
959 zl = ziplistPush(zl,(unsigned char*)scorebuf,scorelen,ZIPLIST_TAIL); in zzlInsertAt()
962 offset = eptr-zl; in zzlInsertAt()
963 zl = ziplistInsert(zl,eptr,ele->ptr,sdslen(ele->ptr)); in zzlInsertAt()
964 eptr = zl+offset; in zzlInsertAt()
967 serverAssertWithInfo(NULL,ele,(sptr = ziplistNext(zl,eptr)) != NULL); in zzlInsertAt()
968 zl = ziplistInsert(zl,sptr,(unsigned char*)scorebuf,scorelen); in zzlInsertAt()
971 return zl; in zzlInsertAt()
976 unsigned char *zzlInsert(unsigned char *zl, robj *ele, double score) { in zzlInsert() argument
977 unsigned char *eptr = ziplistIndex(zl,0), *sptr; in zzlInsert()
982 sptr = ziplistNext(zl,eptr); in zzlInsert()
990 zl = zzlInsertAt(zl,eptr,ele,score); in zzlInsert()
995 zl = zzlInsertAt(zl,eptr,ele,score); in zzlInsert()
1001 eptr = ziplistNext(zl,sptr); in zzlInsert()
1006 zl = zzlInsertAt(zl,NULL,ele,score); in zzlInsert()
1009 return zl; in zzlInsert()
1012 unsigned char *zzlDeleteRangeByScore(unsigned char *zl, zrangespec *range, unsigned long *deleted) { in zzlDeleteRangeByScore() argument
1019 eptr = zzlFirstInRange(zl,range); in zzlDeleteRangeByScore()
1020 if (eptr == NULL) return zl; in zzlDeleteRangeByScore()
1024 while ((sptr = ziplistNext(zl,eptr)) != NULL) { in zzlDeleteRangeByScore()
1028 zl = ziplistDelete(zl,&eptr); in zzlDeleteRangeByScore()
1029 zl = ziplistDelete(zl,&eptr); in zzlDeleteRangeByScore()
1038 return zl; in zzlDeleteRangeByScore()
1041 unsigned char *zzlDeleteRangeByLex(unsigned char *zl, zlexrangespec *range, unsigned long *deleted)… in zzlDeleteRangeByLex() argument
1047 eptr = zzlFirstInLexRange(zl,range); in zzlDeleteRangeByLex()
1048 if (eptr == NULL) return zl; in zzlDeleteRangeByLex()
1052 while ((sptr = ziplistNext(zl,eptr)) != NULL) { in zzlDeleteRangeByLex()
1055 zl = ziplistDelete(zl,&eptr); in zzlDeleteRangeByLex()
1056 zl = ziplistDelete(zl,&eptr); in zzlDeleteRangeByLex()
1065 return zl; in zzlDeleteRangeByLex()
1070 unsigned char *zzlDeleteRangeByRank(unsigned char *zl, unsigned int start, unsigned int end, unsign… in zzlDeleteRangeByRank() argument
1073 zl = ziplistDeleteRange(zl,2*(start-1),2*num); in zzlDeleteRangeByRank()
1074 return zl; in zzlDeleteRangeByRank()
1101 unsigned char *zl = zobj->ptr; in zsetConvert() local
1114 eptr = ziplistIndex(zl,0); in zsetConvert()
1116 sptr = ziplistNext(zl,eptr); in zsetConvert()
1131 zzlNext(zl,&eptr,&sptr); in zsetConvert()
1138 unsigned char *zl = ziplistNew(); in zsetConvert() local
1153 zl = zzlInsertAt(zl,NULL,ele,node->score); in zsetConvert()
1162 zobj->ptr = zl; in zsetConvert()
1610 unsigned char *zl; member
1612 } zl; member
1665 it->zl.zl = op->subject->ptr; in zuiInitIterator()
1666 it->zl.eptr = ziplistIndex(it->zl.zl,0); in zuiInitIterator()
1667 if (it->zl.eptr != NULL) { in zuiInitIterator()
1668 it->zl.sptr = ziplistNext(it->zl.zl,it->zl.eptr); in zuiInitIterator()
1669 serverAssert(it->zl.sptr != NULL); in zuiInitIterator()
1775 if (it->zl.eptr == NULL || it->zl.sptr == NULL) in zuiNext()
1777 serverAssert(ziplistGet(it->zl.eptr,&val->estr,&val->elen,&val->ell)); in zuiNext()
1778 val->score = zzlGetScore(it->zl.sptr); in zuiNext()
1781 zzlNext(it->zl.zl,&it->zl.eptr,&it->zl.sptr); in zuiNext()
2223 unsigned char *zl = zobj->ptr; in zrangeGenericCommand() local
2230 eptr = ziplistIndex(zl,-2-(2*start)); in zrangeGenericCommand()
2232 eptr = ziplistIndex(zl,2*start); in zrangeGenericCommand()
2235 sptr = ziplistNext(zl,eptr); in zrangeGenericCommand()
2249 zzlPrev(zl,&eptr,&sptr); in zrangeGenericCommand()
2251 zzlNext(zl,&eptr,&sptr); in zrangeGenericCommand()
2343 unsigned char *zl = zobj->ptr; in genericZrangebyscoreCommand() local
2352 eptr = zzlLastInRange(zl,&range); in genericZrangebyscoreCommand()
2354 eptr = zzlFirstInRange(zl,&range); in genericZrangebyscoreCommand()
2365 sptr = ziplistNext(zl,eptr); in genericZrangebyscoreCommand()
2376 zzlPrev(zl,&eptr,&sptr); in genericZrangebyscoreCommand()
2378 zzlNext(zl,&eptr,&sptr); in genericZrangebyscoreCommand()
2408 zzlPrev(zl,&eptr,&sptr); in genericZrangebyscoreCommand()
2410 zzlNext(zl,&eptr,&sptr); in genericZrangebyscoreCommand()
2504 unsigned char *zl = zobj->ptr; in zcountCommand() local
2509 eptr = zzlFirstInRange(zl,&range); in zcountCommand()
2518 sptr = ziplistNext(zl,eptr); in zcountCommand()
2531 zzlNext(zl,&eptr,&sptr); in zcountCommand()
2585 unsigned char *zl = zobj->ptr; in zlexcountCommand() local
2589 eptr = zzlFirstInLexRange(zl,&range); in zlexcountCommand()
2599 sptr = ziplistNext(zl,eptr); in zlexcountCommand()
2609 zzlNext(zl,&eptr,&sptr); in zlexcountCommand()
2695 unsigned char *zl = zobj->ptr; in genericZrangebylexCommand() local
2703 eptr = zzlLastInLexRange(zl,&range); in genericZrangebylexCommand()
2705 eptr = zzlFirstInLexRange(zl,&range); in genericZrangebylexCommand()
2717 sptr = ziplistNext(zl,eptr); in genericZrangebylexCommand()
2728 zzlPrev(zl,&eptr,&sptr); in genericZrangebylexCommand()
2730 zzlNext(zl,&eptr,&sptr); in genericZrangebylexCommand()
2755 zzlPrev(zl,&eptr,&sptr); in genericZrangebylexCommand()
2757 zzlNext(zl,&eptr,&sptr); in genericZrangebylexCommand()
2867 unsigned char *zl = zobj->ptr; in zrankGenericCommand() local
2870 eptr = ziplistIndex(zl,0); in zrankGenericCommand()
2872 sptr = ziplistNext(zl,eptr); in zrankGenericCommand()
2880 zzlNext(zl,&eptr,&sptr); in zrankGenericCommand()