Lines Matching refs:eptr

431     char *eptr;  in zslParseRange()  local
442 spec->min = strtod((char*)min->ptr+1,&eptr); in zslParseRange()
443 if (eptr[0] != '\0' || isnan(spec->min)) return C_ERR; in zslParseRange()
446 spec->min = strtod((char*)min->ptr,&eptr); in zslParseRange()
447 if (eptr[0] != '\0' || isnan(spec->min)) return C_ERR; in zslParseRange()
454 spec->max = strtod((char*)max->ptr+1,&eptr); in zslParseRange()
455 if (eptr[0] != '\0' || isnan(spec->max)) return C_ERR; in zslParseRange()
458 spec->max = strtod((char*)max->ptr,&eptr); in zslParseRange()
459 if (eptr[0] != '\0' || isnan(spec->max)) return C_ERR; in zslParseRange()
675 int zzlCompareElements(unsigned char *eptr, unsigned char *cstr, unsigned int clen) { in zzlCompareElements() argument
682 serverAssert(ziplistGet(eptr,&vstr,&vlen,&vlong)); in zzlCompareElements()
701 void zzlNext(unsigned char *zl, unsigned char **eptr, unsigned char **sptr) { in zzlNext() argument
703 serverAssert(*eptr != NULL && *sptr != NULL); in zzlNext()
714 *eptr = _eptr; in zzlNext()
720 void zzlPrev(unsigned char *zl, unsigned char **eptr, unsigned char **sptr) { in zzlPrev() argument
722 serverAssert(*eptr != NULL && *sptr != NULL); in zzlPrev()
724 _sptr = ziplistPrev(zl,*eptr); in zzlPrev()
733 *eptr = _eptr; in zzlPrev()
766 unsigned char *eptr = ziplistIndex(zl,0), *sptr; in zzlFirstInRange() local
772 while (eptr != NULL) { in zzlFirstInRange()
773 sptr = ziplistNext(zl,eptr); in zzlFirstInRange()
780 return eptr; in zzlFirstInRange()
785 eptr = ziplistNext(zl,sptr); in zzlFirstInRange()
794 unsigned char *eptr = ziplistIndex(zl,-2), *sptr; in zzlLastInRange() local
800 while (eptr != NULL) { in zzlLastInRange()
801 sptr = ziplistNext(zl,eptr); in zzlLastInRange()
808 return eptr; in zzlLastInRange()
814 sptr = ziplistPrev(zl,eptr); in zzlLastInRange()
816 serverAssert((eptr = ziplistPrev(zl,sptr)) != NULL); in zzlLastInRange()
818 eptr = NULL; in zzlLastInRange()
865 unsigned char *eptr = ziplistIndex(zl,0), *sptr; in zzlFirstInLexRange() local
870 while (eptr != NULL) { in zzlFirstInLexRange()
871 if (zzlLexValueGteMin(eptr,range)) { in zzlFirstInLexRange()
873 if (zzlLexValueLteMax(eptr,range)) in zzlFirstInLexRange()
874 return eptr; in zzlFirstInLexRange()
879 sptr = ziplistNext(zl,eptr); /* This element score. Skip it. */ in zzlFirstInLexRange()
881 eptr = ziplistNext(zl,sptr); /* Next element. */ in zzlFirstInLexRange()
890 unsigned char *eptr = ziplistIndex(zl,-2), *sptr; in zzlLastInLexRange() local
895 while (eptr != NULL) { in zzlLastInLexRange()
896 if (zzlLexValueLteMax(eptr,range)) { in zzlLastInLexRange()
898 if (zzlLexValueGteMin(eptr,range)) in zzlLastInLexRange()
899 return eptr; in zzlLastInLexRange()
905 sptr = ziplistPrev(zl,eptr); in zzlLastInLexRange()
907 serverAssert((eptr = ziplistPrev(zl,sptr)) != NULL); in zzlLastInLexRange()
909 eptr = NULL; in zzlLastInLexRange()
916 unsigned char *eptr = ziplistIndex(zl,0), *sptr; in zzlFind() local
919 while (eptr != NULL) { in zzlFind()
920 sptr = ziplistNext(zl,eptr); in zzlFind()
923 if (ziplistCompare(eptr,ele->ptr,sdslen(ele->ptr))) { in zzlFind()
927 return eptr; in zzlFind()
931 eptr = ziplistNext(zl,sptr); in zzlFind()
940 unsigned char *zzlDelete(unsigned char *zl, unsigned char *eptr) { in zzlDelete() argument
941 unsigned char *p = eptr; in zzlDelete()
949 unsigned char *zzlInsertAt(unsigned char *zl, unsigned char *eptr, robj *ele, double score) { in zzlInsertAt() argument
957 if (eptr == NULL) { 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()
977 unsigned char *eptr = ziplistIndex(zl,0), *sptr; in zzlInsert() local
981 while (eptr != NULL) { in zzlInsert()
982 sptr = ziplistNext(zl,eptr); in zzlInsert()
990 zl = zzlInsertAt(zl,eptr,ele,score); in zzlInsert()
994 if (zzlCompareElements(eptr,ele->ptr,sdslen(ele->ptr)) > 0) { in zzlInsert()
995 zl = zzlInsertAt(zl,eptr,ele,score); in zzlInsert()
1001 eptr = ziplistNext(zl,sptr); in zzlInsert()
1005 if (eptr == NULL) in zzlInsert()
1013 unsigned char *eptr, *sptr; in zzlDeleteRangeByScore() local
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()
1042 unsigned char *eptr, *sptr; in zzlDeleteRangeByLex() local
1047 eptr = zzlFirstInLexRange(zl,range); in zzlDeleteRangeByLex()
1048 if (eptr == NULL) return zl; in zzlDeleteRangeByLex()
1052 while ((sptr = ziplistNext(zl,eptr)) != NULL) { in zzlDeleteRangeByLex()
1053 if (zzlLexValueLteMax(eptr,range)) { in zzlDeleteRangeByLex()
1055 zl = ziplistDelete(zl,&eptr); in zzlDeleteRangeByLex()
1056 zl = ziplistDelete(zl,&eptr); in zzlDeleteRangeByLex()
1102 unsigned char *eptr, *sptr; in zsetConvert() local
1114 eptr = ziplistIndex(zl,0); in zsetConvert()
1115 serverAssertWithInfo(NULL,zobj,eptr != NULL); in zsetConvert()
1116 sptr = ziplistNext(zl,eptr); in zsetConvert()
1119 while (eptr != NULL) { in zsetConvert()
1121 serverAssertWithInfo(NULL,zobj,ziplistGet(eptr,&vstr,&vlen,&vlong)); in zsetConvert()
1131 zzlNext(zl,&eptr,&sptr); in zsetConvert()
1301 unsigned char *eptr; in zaddGenericCommand() local
1305 if ((eptr = zzlFind(zobj->ptr,ele,&curscore)) != NULL) { in zaddGenericCommand()
1317 zobj->ptr = zzlDelete(zobj->ptr,eptr); in zaddGenericCommand()
1420 unsigned char *eptr; in zremCommand() local
1423 if ((eptr = zzlFind(zobj->ptr,c->argv[j],NULL)) != NULL) { in zremCommand()
1425 zobj->ptr = zzlDelete(zobj->ptr,eptr); in zremCommand()
1611 unsigned char *eptr, *sptr; member
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()
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()
1781 zzlNext(it->zl.zl,&it->zl.eptr,&it->zl.sptr); in zuiNext()
2224 unsigned char *eptr, *sptr; in zrangeGenericCommand() local
2230 eptr = ziplistIndex(zl,-2-(2*start)); in zrangeGenericCommand()
2232 eptr = ziplistIndex(zl,2*start); in zrangeGenericCommand()
2234 serverAssertWithInfo(c,zobj,eptr != NULL); in zrangeGenericCommand()
2235 sptr = ziplistNext(zl,eptr); in zrangeGenericCommand()
2238 serverAssertWithInfo(c,zobj,eptr != NULL && sptr != NULL); in zrangeGenericCommand()
2239 serverAssertWithInfo(c,zobj,ziplistGet(eptr,&vstr,&vlen,&vlong)); in zrangeGenericCommand()
2249 zzlPrev(zl,&eptr,&sptr); in zrangeGenericCommand()
2251 zzlNext(zl,&eptr,&sptr); in zrangeGenericCommand()
2344 unsigned char *eptr, *sptr; in genericZrangebyscoreCommand() local
2352 eptr = zzlLastInRange(zl,&range); in genericZrangebyscoreCommand()
2354 eptr = zzlFirstInRange(zl,&range); in genericZrangebyscoreCommand()
2358 if (eptr == NULL) { in genericZrangebyscoreCommand()
2364 serverAssertWithInfo(c,zobj,eptr != NULL); in genericZrangebyscoreCommand()
2365 sptr = ziplistNext(zl,eptr); in genericZrangebyscoreCommand()
2374 while (eptr && offset--) { in genericZrangebyscoreCommand()
2376 zzlPrev(zl,&eptr,&sptr); in genericZrangebyscoreCommand()
2378 zzlNext(zl,&eptr,&sptr); in genericZrangebyscoreCommand()
2382 while (eptr && limit--) { in genericZrangebyscoreCommand()
2393 serverAssertWithInfo(c,zobj,ziplistGet(eptr,&vstr,&vlen,&vlong)); in genericZrangebyscoreCommand()
2408 zzlPrev(zl,&eptr,&sptr); in genericZrangebyscoreCommand()
2410 zzlNext(zl,&eptr,&sptr); in genericZrangebyscoreCommand()
2505 unsigned char *eptr, *sptr; in zcountCommand() local
2509 eptr = zzlFirstInRange(zl,&range); in zcountCommand()
2512 if (eptr == NULL) { in zcountCommand()
2518 sptr = ziplistNext(zl,eptr); in zcountCommand()
2523 while (eptr) { in zcountCommand()
2531 zzlNext(zl,&eptr,&sptr); in zcountCommand()
2586 unsigned char *eptr, *sptr; in zlexcountCommand() local
2589 eptr = zzlFirstInLexRange(zl,&range); in zlexcountCommand()
2592 if (eptr == NULL) { in zlexcountCommand()
2599 sptr = ziplistNext(zl,eptr); in zlexcountCommand()
2600 serverAssertWithInfo(c,zobj,zzlLexValueLteMax(eptr,&range)); in zlexcountCommand()
2603 while (eptr) { in zlexcountCommand()
2605 if (!zzlLexValueLteMax(eptr,&range)) { in zlexcountCommand()
2609 zzlNext(zl,&eptr,&sptr); in zlexcountCommand()
2696 unsigned char *eptr, *sptr; in genericZrangebylexCommand() local
2703 eptr = zzlLastInLexRange(zl,&range); in genericZrangebylexCommand()
2705 eptr = zzlFirstInLexRange(zl,&range); in genericZrangebylexCommand()
2709 if (eptr == NULL) { in genericZrangebylexCommand()
2716 serverAssertWithInfo(c,zobj,eptr != NULL); in genericZrangebylexCommand()
2717 sptr = ziplistNext(zl,eptr); in genericZrangebylexCommand()
2726 while (eptr && offset--) { in genericZrangebylexCommand()
2728 zzlPrev(zl,&eptr,&sptr); in genericZrangebylexCommand()
2730 zzlNext(zl,&eptr,&sptr); in genericZrangebylexCommand()
2734 while (eptr && limit--) { in genericZrangebylexCommand()
2737 if (!zzlLexValueGteMin(eptr,&range)) break; in genericZrangebylexCommand()
2739 if (!zzlLexValueLteMax(eptr,&range)) break; in genericZrangebylexCommand()
2744 serverAssertWithInfo(c,zobj,ziplistGet(eptr,&vstr,&vlen,&vlong)); in genericZrangebylexCommand()
2755 zzlPrev(zl,&eptr,&sptr); in genericZrangebylexCommand()
2757 zzlNext(zl,&eptr,&sptr); in genericZrangebylexCommand()
2868 unsigned char *eptr, *sptr; in zrankGenericCommand() local
2870 eptr = ziplistIndex(zl,0); in zrankGenericCommand()
2871 serverAssertWithInfo(c,zobj,eptr != NULL); in zrankGenericCommand()
2872 sptr = ziplistNext(zl,eptr); in zrankGenericCommand()
2876 while(eptr != NULL) { in zrankGenericCommand()
2877 if (ziplistCompare(eptr,ele->ptr,sdslen(ele->ptr))) in zrankGenericCommand()
2880 zzlNext(zl,&eptr,&sptr); in zrankGenericCommand()
2883 if (eptr != NULL) { in zrankGenericCommand()