Tests for lua globals protection.

[redis.git] / src / rdb.c

diff --git a/src/rdb.c b/src/rdb.c
index 519b645d157281e86b6e2213ddfdfb648e36069a..1e23fa70cf392b399806ce9a7086af65114dd7c2 100644 (file)
--- a/src/rdb.c
+++ b/src/rdb.c
@@ -859,14 +859,17 @@ robj *rdbLoadObject(int rdbtype, rio *rdb) {
             /* Add pair to ziplist */
             o->ptr = ziplistPush(o->ptr, field->ptr, sdslen(field->ptr), ZIPLIST_TAIL);
             o->ptr = ziplistPush(o->ptr, value->ptr, sdslen(value->ptr), ZIPLIST_TAIL);
             /* Add pair to ziplist */
             o->ptr = ziplistPush(o->ptr, field->ptr, sdslen(field->ptr), ZIPLIST_TAIL);
             o->ptr = ziplistPush(o->ptr, value->ptr, sdslen(value->ptr), ZIPLIST_TAIL);

-

             /* Convert to hash table if size threshold is exceeded */
             if (sdslen(field->ptr) > server.hash_max_ziplist_value ||
                 sdslen(value->ptr) > server.hash_max_ziplist_value)
             {
             /* Convert to hash table if size threshold is exceeded */
             if (sdslen(field->ptr) > server.hash_max_ziplist_value ||
                 sdslen(value->ptr) > server.hash_max_ziplist_value)
             {

+                decrRefCount(field);
+                decrRefCount(value);

                 hashTypeConvert(o, REDIS_ENCODING_HT);
                 break;
             }
                 hashTypeConvert(o, REDIS_ENCODING_HT);
                 break;
             }

+            decrRefCount(field);
+            decrRefCount(value);

         }
 
         /* Load remaining fields and values into the hash table */
         }
 
         /* Load remaining fields and values into the hash table */