| /f-stack/app/redis-5.0.5/src/ |
| H A D | t_zset.c | 75 zn->ele = ele; in zslCreateNode() 492 if (x->ele && sdscmp(x->ele,ele) == 0) { in zslGetRank() 1171 sds ele; in zsetConvert() local 1406 ele = sdsdup(ele); in zsetAdd() 1537 sds ele; in zaddGenericCommand() local 2004 val->ele = it->sl.node->ele; in zuiNext() 2053 sds ele = val->ele; in zuiNewSdsFromValue() local 2502 ele = ln->ele; in zrangeGenericCommand() 2503 addReplyBulkCBuffer(c,ele,sdslen(ele)); in zrangeGenericCommand() 3208 ele = sdsdup(zln->ele); in genericZpopCommand() [all …]
|
| H A D | listpack.c | 604 if (ele == NULL) where = LP_REPLACE; in lpInsert() 628 if (ele) { in lpInsert() 688 if (ele) { in lpInsert() 703 if (ele) in lpInsert() 789 while (index > 0 && ele) { in lpSeek() 790 ele = lpNext(lp,ele); in lpSeek() 793 return ele; in lpSeek() 795 unsigned char *ele = lpLast(lp); in lpSeek() local 796 while (index < -1 && ele) { in lpSeek() 797 ele = lpPrev(lp,ele); in lpSeek() [all …]
|
| H A D | t_set.c | 322 ele = c->argv[3]; in smoveCommand() 592 addReplyBulk(c,ele); in spopCommand() 593 decrRefCount(ele); in spopCommand() 619 sds ele; in srandmemberWithCountCommand() local 656 addReplyBulkCBuffer(c,ele,sdslen(ele)); in srandmemberWithCountCommand() 693 retval = dictAdd(d,createStringObject(ele,sdslen(ele)),NULL); in srandmemberWithCountCommand() 723 objele = createStringObject(ele,sdslen(ele)); in srandmemberWithCountCommand() 751 sds ele; in srandmemberCommand() local 770 addReplyBulkCBuffer(c,ele,sdslen(ele)); in srandmemberCommand() 936 sds ele; in sunionDiffGenericCommand() local [all …]
|
| H A D | listpack.h | 49 unsigned char *lpInsert(unsigned char *lp, unsigned char *ele, uint32_t size, unsigned char *p, int… 50 unsigned char *lpAppend(unsigned char *lp, unsigned char *ele, uint32_t size);
|
| H A D | hyperloglog.c | 451 int hllPatLen(unsigned char *ele, size_t elesize, long *regp) { in hllPatLen() argument 466 hash = MurmurHash64A(ele,elesize,0xadc83b19ULL); in hllPatLen() 513 uint8_t count = hllPatLen(ele,elesize,&index); in hllDenseAdd() 903 int hllSparseAdd(robj *o, unsigned char *ele, size_t elesize) { in hllSparseAdd() argument 905 uint8_t count = hllPatLen(ele,elesize,&index); in hllSparseAdd() 1051 int hllAdd(robj *o, unsigned char *ele, size_t elesize) { in hllAdd() argument 1055 case HLL_SPARSE: return hllSparseAdd(o,ele,elesize); in hllAdd() 1439 uint64_t ele; in pfselftestCommand() local 1441 ele = j ^ seed; in pfselftestCommand() 1442 hllDenseAdd(hdr->registers,(unsigned char*)&ele,sizeof(ele)); in pfselftestCommand() [all …]
|
| H A D | defrag.c | 216 sds ele = newele? newele: oldele; in zslDefrag() local 223 x->level[i].forward->ele != oldele && /* make sure not to access the in zslDefrag() 228 sdscmp(x->level[i].forward->ele,ele) < 0))) in zslDefrag() 235 serverAssert(x && score == x->score && x->ele==oldele); in zslDefrag() 237 x->ele = newele; in zslDefrag() 286 robj *newele, *ele = dictGetVal(de); in activeDefragSdsDict() local 287 if ((newele = activeDefragStringOb(ele, &defragged))) in activeDefragSdsDict() 322 robj *newele, *ele = ln->value; in activeDefragList() local 323 if ((newele = activeDefragStringOb(ele, &defragged))) in activeDefragList() 373 robj *newele, *ele = dictGetVal(de); in activeDefragSdsListAndDict() local [all …]
|
| H A D | geo.c | 272 sds ele = ln->ele; in geoGetPointsInRange() local 277 ele = sdsdup(ele); in geoGetPointsInRange() 278 if (geoAppendIfWithinRadius(ga,lon,lat,radius,ln->score,ele) in geoGetPointsInRange() 279 == C_ERR) sdsfree(ele); in geoGetPointsInRange()
|
| H A D | redismodule.h | 208 … REDISMODULE_API_FUNC(RedisModule_ListPush)(RedisModuleKey *kp, int where, RedisModuleString *ele); 246 …UNC(RedisModule_ZsetAdd)(RedisModuleKey *key, double score, RedisModuleString *ele, int *flagsptr); 247 …isModule_ZsetIncrby)(RedisModuleKey *key, double score, RedisModuleString *ele, int *flagsptr, dou… 248 int REDISMODULE_API_FUNC(RedisModule_ZsetScore)(RedisModuleKey *key, RedisModuleString *ele, double… 249 int REDISMODULE_API_FUNC(RedisModule_ZsetRem)(RedisModuleKey *key, RedisModuleString *ele, int *del… 291 …API_FUNC(RedisModule_DigestAddStringBuffer)(RedisModuleDigest *md, unsigned char *ele, size_t len); 292 void REDISMODULE_API_FUNC(RedisModule_DigestAddLongLong)(RedisModuleDigest *md, long long ele);
|
| H A D | module.c | 1770 listTypePush(key->value, ele, in RM_ListPush() 1786 robj *ele = listTypePop(key->value, in RM_ListPop() local 1788 robj *decoded = getDecodedObject(ele); in RM_ListPop() 1789 decrRefCount(ele); in RM_ListPop() 2095 sds ele = ziplistGetObject(eptr); in RM_ZsetRangeCurrentElement() local 2104 str = createStringObject(ln->ele,sdslen(ln->ele)); in RM_ZsetRangeCurrentElement() 2550 ele->proto = p; in moduleParseCallReply_Array() 2551 ele->ctx = reply->ctx; in moduleParseCallReply_Array() 2552 moduleParseCallReply(ele); in moduleParseCallReply_Array() 2553 p += ele->protolen; in moduleParseCallReply_Array() [all …]
|
| H A D | rax.h | 200 int raxSeek(raxIterator *it, const char *op, unsigned char *ele, size_t len);
|
| H A D | object.c | 781 sds ele, ele2; in objectComputeSize() local 818 ele = dictGetKey(de); in objectComputeSize() 819 elesize += sizeof(struct dictEntry) + sdsAllocSize(ele); in objectComputeSize() 839 elesize += sdsAllocSize(znode->ele); in objectComputeSize() 856 ele = dictGetKey(de); in objectComputeSize() 858 elesize += sdsAllocSize(ele) + sdsAllocSize(ele2); in objectComputeSize()
|
| H A D | rdb.c | 799 sds ele = dictGetKey(de); in rdbSaveObject() local 800 if ((n = rdbSaveRawString(rdb,(unsigned char*)ele,sdslen(ele))) in rdbSaveObject() 840 (unsigned char*)zn->ele,sdslen(zn->ele))) == -1) in rdbSaveObject() 1385 robj *o = NULL, *ele, *dec; in rdbLoadObject() local 1403 if ((ele = rdbLoadEncodedStringObject(rdb)) == NULL) return NULL; in rdbLoadObject() 1404 dec = getDecodedObject(ele); in rdbLoadObject() 1408 decrRefCount(ele); in rdbLoadObject()
|
| H A D | aof.c | 981 sds ele = dictGetKey(de); in rewriteSetObject() local 990 if (rioWriteBulkString(r,ele,sdslen(ele)) == 0) return 0; in rewriteSetObject() 1047 sds ele = dictGetKey(de); in rewriteSortedSetObject() local 1059 if (rioWriteBulkString(r,ele,sdslen(ele)) == 0) return 0; in rewriteSortedSetObject()
|
| /f-stack/app/redis-5.0.5/utils/hyperloglog/ |
| H A D | hll-gnuplot-graph.rb | 29 ele = Digest::SHA1.hexdigest(i.to_s+seed.to_s) 30 elements << ele 49 dataset[0].each_with_index{|ele,index| 51 card=ele[0] 52 err=ele[1].abs 58 card=ele[0] 66 card=ele[0]
|
| H A D | hll-err.rb | 17 ele = Digest::SHA1.hexdigest(i.to_s) 18 elements << ele
|
| /f-stack/app/redis-5.0.5/src/modules/ |
| H A D | helloworld.c | 123 strlen += RedisModule_CallReplyLength(ele); in HelloListSumLen_RedisCommand() 162 RedisModuleString *ele; in HelloListSplice_RedisCommand() local 165 if (ele == NULL) break; in HelloListSplice_RedisCommand() 166 RedisModule_ListPush(dstkey,REDISMODULE_LIST_HEAD,ele); in HelloListSplice_RedisCommand() 167 RedisModule_FreeString(ctx,ele); in HelloListSplice_RedisCommand() 206 RedisModuleString *ele; in HelloListSpliceAuto_RedisCommand() local 209 if (ele == NULL) break; in HelloListSpliceAuto_RedisCommand() 398 RedisModule_FreeString(ctx,ele); in HelloZsumRange_RedisCommand() 408 RedisModule_FreeString(ctx,ele); in HelloZsumRange_RedisCommand() 450 RedisModule_ReplyWithString(ctx,ele); in HelloLexRange_RedisCommand() [all …]
|
| H A D | hellotype.c | 71 void HelloTypeInsert(struct HelloTypeObject *o, int64_t ele) { in HelloTypeInsert() argument 74 while(next && next->value < ele) { in HelloTypeInsert() 79 newnode->value = ele; in HelloTypeInsert() 204 int64_t ele = RedisModule_LoadSigned(rdb); in HelloTypeRdbLoad() local 205 HelloTypeInsert(hto,ele); in HelloTypeRdbLoad()
|
| H A D | helloblock.c | 163 RedisModuleCallReply *ele = in HelloKeys_ThreadMain() local 165 RedisModule_ReplyWithCallReply(ctx,ele); in HelloKeys_ThreadMain()
|
| /f-stack/app/redis-5.0.5/tests/unit/type/ |
| H A D | list-3.tcl | 35 set ele [randomInt 1000] 37 set ele [string repeat x [randomInt 10000]][randomInt 1000] 40 0 {r lpush key $ele} 41 1 {r rpush key $ele} 45 catch {r lset key $small_signed_count $ele} 54 r linsert key $where $otherele $ele
|
| H A D | set.tcl | 234 set ele [randomValue] 235 r sadd set_$i $ele 237 set s($ele) x 401 foreach ele [r smembers myset] { 402 set myset($ele) 1 421 foreach ele $res { 431 foreach ele $res { 432 set auxset($ele) 1 465 foreach ele $res { 475 foreach ele $res { [all …]
|
| /f-stack/app/redis-5.0.5/tests/cluster/tests/ |
| H A D | 04-resharding.tcl | 62 set ele 0 90 incr ele 96 $cluster rpush $key $ele 98 $cluster eval {redis.call("rpush",KEYS[1],ARGV[1])} 1 $key $ele 100 lappend content($key) $ele
|
| H A D | 10-manual-failover.tcl | 42 set ele [randomValue] 48 $cluster rpush $key $ele 50 $cluster eval {redis.call("rpush",KEYS[1],ARGV[1])} 1 $key $ele 52 lappend content($key) $ele
|
| /f-stack/freebsd/contrib/openzfs/cmd/dbufstat/ |
| H A D | dbufstat.in | 636 for ele in hdr: 637 if ele not in cols: 638 invalid.append(ele) 639 elif ((bflag and bincompat and ele in bincompat) or 640 (dflag and dincompat and ele in dincompat) or 641 (tflag and tincompat and ele in tincompat)): 642 incompat.append(ele)
|
| /f-stack/freebsd/contrib/openzfs/cmd/arcstat/ |
| H A D | arcstat.in | 405 for ele in hdr: 406 if ele not in cols: 407 invalid.append(ele) 408 elif not l2exist and ele.startswith("l2"): 409 sys.stdout.write("No L2ARC Here\n%s\n" % ele) 410 incompat.append(ele)
|
| /f-stack/lib/ |
| H A D | ff_memory.c | 95 uint64_t *ele; member 118 if ( posix_memalign((void**)&p->ele, sizeof(uint64_t), sizeof(uint64_t)*size) != 0) in stklist_init() 132 return (void*)p->ele[--p->top]; in stklist_pop() 146 p->ele[p->top++] = val; in stklist_push()
|