mirror of
https://github.com/fluencelabs/redis
synced 2025-06-28 08:21:32 +00:00
Persistence code for encoded sorted sets
This commit is contained in:
11
src/rdb.c
11
src/rdb.c
@ -326,7 +326,13 @@ int rdbSaveObject(FILE *fp, robj *o) {
|
|||||||
redisPanic("Unknown set encoding");
|
redisPanic("Unknown set encoding");
|
||||||
}
|
}
|
||||||
} else if (o->type == REDIS_ZSET) {
|
} else if (o->type == REDIS_ZSET) {
|
||||||
/* Save a set value */
|
/* Save a sorted set value */
|
||||||
|
if (o->encoding == REDIS_ENCODING_ZIPLIST) {
|
||||||
|
size_t l = ziplistBlobLen((unsigned char*)o->ptr);
|
||||||
|
|
||||||
|
if ((n = rdbSaveRawString(fp,o->ptr,l)) == -1) return -1;
|
||||||
|
nwritten += n;
|
||||||
|
} else if (o->encoding == REDIS_ENCODING_RAW) {
|
||||||
zset *zs = o->ptr;
|
zset *zs = o->ptr;
|
||||||
dictIterator *di = dictGetIterator(zs->dict);
|
dictIterator *di = dictGetIterator(zs->dict);
|
||||||
dictEntry *de;
|
dictEntry *de;
|
||||||
@ -344,6 +350,9 @@ int rdbSaveObject(FILE *fp, robj *o) {
|
|||||||
nwritten += n;
|
nwritten += n;
|
||||||
}
|
}
|
||||||
dictReleaseIterator(di);
|
dictReleaseIterator(di);
|
||||||
|
} else {
|
||||||
|
redisPanic("Unknown sorted set enoding");
|
||||||
|
}
|
||||||
} else if (o->type == REDIS_HASH) {
|
} else if (o->type == REDIS_HASH) {
|
||||||
/* Save a hash value */
|
/* Save a hash value */
|
||||||
if (o->encoding == REDIS_ENCODING_ZIPMAP) {
|
if (o->encoding == REDIS_ENCODING_ZIPMAP) {
|
||||||
|
Reference in New Issue
Block a user