| /redis-3.2.3/src/ |
| H A D | intset.c | 82 uint32_t encoding = intrev32ifbe(is->encoding); in _intsetSet() local 84 if (encoding == INTSET_ENC_INT64) { in _intsetSet() 87 } else if (encoding == INTSET_ENC_INT32) { in _intsetSet() 158 uint8_t curenc = intrev32ifbe(is->encoding); in intsetUpgradeAndAdd() 164 is->encoding = intrev32ifbe(newenc); in intsetUpgradeAndAdd() 185 uint32_t encoding = intrev32ifbe(is->encoding); in intsetMoveTail() local 187 if (encoding == INTSET_ENC_INT64) { in intsetMoveTail() 191 } else if (encoding == INTSET_ENC_INT32) { in intsetMoveTail() 212 if (valenc > intrev32ifbe(is->encoding)) { in intsetAdd() 336 uint32_t encoding = intrev32ifbe(is->encoding); in checkConsistency() local [all …]
|
| H A D | t_set.c | 124 si->encoding = subject->encoding; in setTypeInitIterator() 136 if (si->encoding == OBJ_ENCODING_HT) in setTypeReleaseIterator() 169 return si->encoding; in setTypeNext() 182 int encoding; in setTypeNextObject() local 185 switch(encoding) { in setTypeNextObject() 226 return setobj->encoding; in setTypeRandomElement() 471 int encoding; in spopWithCountCommand() local 565 int encoding; in spopCommand() local 628 int encoding; in srandmemberWithCountCommand() local 758 int encoding; in srandmemberCommand() local [all …]
|
| H A D | object.c | 42 o->encoding = OBJ_ENCODING_RAW; in createObject() 65 o->encoding = OBJ_ENCODING_EMBSTR; in createEmbeddedStringObject() 168 switch(o->encoding) { in dupStringObject() 201 o->encoding = OBJ_ENCODING_HT; in createSetObject() 208 o->encoding = OBJ_ENCODING_INTSET; in createIntsetObject() 244 switch (o->encoding) { in freeListObject() 254 switch (o->encoding) { in freeSetObject() 268 switch (o->encoding) { in freeZsetObject() 284 switch (o->encoding) { in freeHashObject() 666 char *strEncoding(int encoding) { in strEncoding() argument [all …]
|
| H A D | ziplist.c | 162 unsigned char encoding; member 169 (zle)->encoding = 0; \ 176 (encoding) = (ptr[0]); \ 177 if ((encoding) < ZIP_STR_MASK) (encoding) &= ZIP_STR_MASK; \ 184 switch(encoding) { in zipIntSize() 201 if (ZIP_IS_STR(encoding)) { in zipEncodeLength() 224 buf[0] = encoding; in zipEncodeLength() 377 } else if (encoding >= ZIP_INT_IMM_MIN && encoding <= ZIP_INT_IMM_MAX) { in zipSaveInteger() 408 } else if (encoding >= ZIP_INT_IMM_MIN && encoding <= ZIP_INT_IMM_MAX) { in zipLoadInteger() 591 unsigned char encoding = 0; in __ziplistInsert() local [all …]
|
| H A D | t_hash.c | 57 if (subject->encoding == OBJ_ENCODING_HT) { in hashTypeTryObjectEncoding() 121 if (o->encoding == OBJ_ENCODING_ZIPLIST) { in hashTypeGetObject() 133 } else if (o->encoding == OBJ_ENCODING_HT) { in hashTypeGetObject() 151 if (o->encoding == OBJ_ENCODING_ZIPLIST) { in hashTypeGetValueLength() 172 if (o->encoding == OBJ_ENCODING_ZIPLIST) { in hashTypeExists() 195 if (o->encoding == OBJ_ENCODING_ZIPLIST) { in hashTypeSet() 249 if (o->encoding == OBJ_ENCODING_ZIPLIST) { in hashTypeDelete() 287 if (o->encoding == OBJ_ENCODING_ZIPLIST) { in hashTypeLength() 301 hi->encoding = subject->encoding; in hashTypeInitIterator() 316 if (hi->encoding == OBJ_ENCODING_HT) { in hashTypeReleaseIterator() [all …]
|
| H A D | t_zset.c | 438 if (min->encoding == OBJ_ENCODING_INT) { in zslParseRange() 450 if (max->encoding == OBJ_ENCODING_INT) { in zslParseRange() 518 if (min->encoding == OBJ_ENCODING_INT || in zslParseLexRange() 1093 void zsetConvert(robj *zobj, int encoding) { in zsetConvert() argument 1099 if (zobj->encoding == encoding) return; in zsetConvert() 1107 if (encoding != OBJ_ENCODING_SKIPLIST) in zsetConvert() 1136 zobj->encoding = OBJ_ENCODING_SKIPLIST; in zsetConvert() 1140 if (encoding != OBJ_ENCODING_ZIPLIST) in zsetConvert() 1163 zobj->encoding = OBJ_ENCODING_ZIPLIST; in zsetConvert() 1590 int encoding; member [all …]
|
| H A D | t_list.c | 42 if (subject->encoding == OBJ_ENCODING_QUICKLIST) { in listTypePush() 62 if (subject->encoding == OBJ_ENCODING_QUICKLIST) { in listTypePop() 87 li->encoding = subject->encoding; in listTypeInitIterator() 94 if (li->encoding == OBJ_ENCODING_QUICKLIST) { in listTypeInitIterator() 114 serverAssert(li->subject->encoding == li->encoding); in listTypeNext() 117 if (li->encoding == OBJ_ENCODING_QUICKLIST) { in listTypeNext() 187 subject->encoding = OBJ_ENCODING_QUICKLIST; in listTypeConvert() 314 if (o->encoding == OBJ_ENCODING_QUICKLIST) { in lindexCommand() 341 if (o->encoding == OBJ_ENCODING_QUICKLIST) { in lsetCommand() 416 if (o->encoding == OBJ_ENCODING_QUICKLIST) { in lrangeCommand() [all …]
|
| H A D | rdb.c | 398 if (obj->encoding == OBJ_ENCODING_INT) { in rdbSaveStringObject() 530 if (o->encoding == OBJ_ENCODING_QUICKLIST) in rdbSaveObjectType() 535 if (o->encoding == OBJ_ENCODING_INTSET) in rdbSaveObjectType() 537 else if (o->encoding == OBJ_ENCODING_HT) in rdbSaveObjectType() 542 if (o->encoding == OBJ_ENCODING_ZIPLIST) in rdbSaveObjectType() 549 if (o->encoding == OBJ_ENCODING_ZIPLIST) in rdbSaveObjectType() 551 else if (o->encoding == OBJ_ENCODING_HT) in rdbSaveObjectType() 603 if (o->encoding == OBJ_ENCODING_HT) { in rdbSaveObject() 627 if (o->encoding == OBJ_ENCODING_ZIPLIST) { in rdbSaveObject() 655 if (o->encoding == OBJ_ENCODING_ZIPLIST) { in rdbSaveObject() [all …]
|
| H A D | hyperloglog.c | 584 hdr->encoding = HLL_DENSE; in hllSparseToDense() 986 if (hdr->encoding == HLL_DENSE) { in hllCount() 988 } else if (hdr->encoding == HLL_SPARSE) { in hllCount() 991 } else if (hdr->encoding == HLL_RAW) { in hllCount() 1029 switch(hdr->encoding) { in hllAdd() 1048 if (hdr->encoding == HLL_DENSE) { in hllMerge() 1117 hdr->encoding = HLL_SPARSE; in createHLLObject() 1141 if (hdr->encoding == HLL_DENSE && in isHLLObjectOrReply() 1474 if (hdr->encoding == HLL_SPARSE) { in pfdebugCommand() 1498 if (hdr->encoding != HLL_SPARSE) { in pfdebugCommand() [all …]
|
| H A D | quicklist.h | 50 unsigned int encoding : 2; /* RAW==1 or LZF==2 */ member 115 ((node)->encoding == QUICKLIST_NODE_ENCODING_LZF)
|
| H A D | intset.h | 36 uint32_t encoding; member
|
| H A D | aof.c | 776 if (obj->encoding == OBJ_ENCODING_INT) { in rioWriteBulkObject() 790 if (o->encoding == OBJ_ENCODING_QUICKLIST) { in rewriteListObject() 824 if (o->encoding == OBJ_ENCODING_INTSET) { in rewriteSetObject() 841 } else if (o->encoding == OBJ_ENCODING_HT) { in rewriteSetObject() 871 if (o->encoding == OBJ_ENCODING_ZIPLIST) { in rewriteSortedSetObject() 906 } else if (o->encoding == OBJ_ENCODING_SKIPLIST) { in rewriteSortedSetObject() 942 if (hi->encoding == OBJ_ENCODING_ZIPLIST) { in rioWriteHashIteratorCursor() 954 } else if (hi->encoding == OBJ_ENCODING_HT) { in rioWriteHashIteratorCursor()
|
| H A D | quicklist.c | 145 node->encoding = QUICKLIST_NODE_ENCODING_RAW; in quicklistCreateNode() 200 node->encoding = QUICKLIST_NODE_ENCODING_LZF; in __quicklistCompressNode() 208 if ((_node) && (_node)->encoding == QUICKLIST_NODE_ENCODING_RAW) { \ 229 node->encoding = QUICKLIST_NODE_ENCODING_RAW; in __quicklistDecompressNode() 236 if ((_node) && (_node)->encoding == QUICKLIST_NODE_ENCODING_LZF) { \ 244 if ((_node) && (_node)->encoding == QUICKLIST_NODE_ENCODING_LZF) { \ 1195 if (node->encoding == QUICKLIST_NODE_ENCODING_LZF) { in quicklistDup() 1200 } else if (node->encoding == QUICKLIST_NODE_ENCODING_RAW) { in quicklistDup() 1208 node->encoding = current->encoding; in quicklistDup() 1577 if (node->encoding != QUICKLIST_NODE_ENCODING_RAW) { in _ql_verify() [all …]
|
| H A D | server.h | 465 unsigned encoding:4; member 484 _var.encoding = OBJ_ENCODING_RAW; \ 1026 unsigned char encoding; member 1040 int encoding; member 1051 int encoding; member 1219 char *strEncoding(int encoding); 1224 #define sdsEncodedObject(objptr) (objptr->encoding == OBJ_ENCODING_RAW || objptr->encoding == OBJ_E… 1300 void zsetConvert(robj *zobj, int encoding);
|
| H A D | debug.c | 175 if (o->encoding == OBJ_ENCODING_ZIPLIST) { in computeDatasetDigest() 205 } else if (o->encoding == OBJ_ENCODING_SKIPLIST) { in computeDatasetDigest() 366 strenc = strEncoding(val->encoding); in debugCommand() 369 if (val->encoding == OBJ_ENCODING_QUICKLIST) { in debugCommand() 584 c->argv[j]->type, c->argv[j]->encoding); in _serverAssertPrintClientInfo() 594 serverLog(LL_WARNING,"Object encoding: %d", o->encoding); in serverLogObjectDebugInfo() 611 if (o->encoding == OBJ_ENCODING_SKIPLIST) in serverLogObjectDebugInfo()
|
| H A D | db.c | 267 if (o->refcount != 1 || o->encoding != OBJ_ENCODING_RAW) { in dbUnshareStringValue() 551 } else if (o->type == OBJ_SET && o->encoding == OBJ_ENCODING_HT) { in scanGenericCommand() 553 } else if (o->type == OBJ_HASH && o->encoding == OBJ_ENCODING_HT) { in scanGenericCommand() 556 } else if (o->type == OBJ_ZSET && o->encoding == OBJ_ENCODING_SKIPLIST) { in scanGenericCommand() 621 serverAssert(kobj->encoding == OBJ_ENCODING_INT); in scanGenericCommand()
|
| H A D | geo.c | 232 if (zobj->encoding == OBJ_ENCODING_ZIPLIST) { in geoGetPointsInRange() 261 } else if (zobj->encoding == OBJ_ENCODING_SKIPLIST) { in geoGetPointsInRange() 277 member = (o->encoding == OBJ_ENCODING_INT) ? in geoGetPointsInRange()
|
| H A D | networking.c | 48 switch(o->encoding) { in getStringObjectSdsUsedMemory() 244 tail->encoding == OBJ_ENCODING_RAW && in _addReplyObjectToList() 277 if (tail->ptr != NULL && tail->encoding == OBJ_ENCODING_RAW && in _addReplySdsToList() 307 if (tail->ptr != NULL && tail->encoding == OBJ_ENCODING_RAW && in _addReplyStringToList() 342 } else if (obj->encoding == OBJ_ENCODING_INT) { in addReply() 451 len->encoding = OBJ_ENCODING_RAW; /* in case it was an EMBSTR. */ in setDeferredMultiBulkLength()
|
| H A D | t_string.c | 257 if (o->encoding == OBJ_ENCODING_INT) { in getrangeCommand() 357 if (o && o->refcount == 1 && o->encoding == OBJ_ENCODING_INT && in incrDecrCommand()
|
| H A D | sort.c | 472 } else if (byval->encoding == OBJ_ENCODING_INT) { in sortCommand()
|
| H A D | server.c | 500 if (o1->encoding == OBJ_ENCODING_INT && in dictEncObjKeyCompare() 501 o2->encoding == OBJ_ENCODING_INT) in dictEncObjKeyCompare() 518 if (o->encoding == OBJ_ENCODING_INT) { in dictEncObjHash() 1433 shared.integers[j]->encoding = OBJ_ENCODING_INT; in createSharedObjects()
|
| H A D | replication.c | 163 if (o->encoding == OBJ_ENCODING_INT) { in feedReplicationBacklogWithObject() 287 if (argv[j]->encoding == OBJ_ENCODING_INT) { in replicationFeedMonitors()
|
| H A D | scripting.c | 603 (o->encoding == OBJ_ENCODING_RAW || in luaRedisGenericCommand() 604 o->encoding == OBJ_ENCODING_EMBSTR) && in luaRedisGenericCommand()
|
| H A D | bitops.c | 505 if (o && o->encoding == OBJ_ENCODING_INT) { in getObjectReadOnlyString()
|
| /redis-3.2.3/ |
| H A D | 00-RELEASENOTES | 1676 * [NEW] New encoding for the List type: Quicklists. Very important memory 1712 * As a side effect of quicklists encoding (see above items), moving big
|