RDB memory leaks

Former-commit-id: 6208118b133c7f4209fd0a55d2a75341407e3e2c
This commit is contained in:
John Sully 2020-01-30 17:57:10 -05:00
parent 24c9edd93b
commit 8ea5d731ad

View File

@ -1632,9 +1632,17 @@ robj *rdbLoadObject(int rdbtype, rio *rdb, robj *key, uint64_t mvcc_tstamp) {
len--;
/* Load raw strings */
if ((field = (sds)rdbGenericLoadStringObject(rdb,RDB_LOAD_SDS,NULL))
== NULL) return NULL;
== NULL)
{
decrRefCount(o);
return NULL;
}
if ((value = (sds)rdbGenericLoadStringObject(rdb,RDB_LOAD_SDS,NULL))
== NULL) return NULL;
== NULL)
{
decrRefCount(o);
return NULL;
}
/* Add pair to ziplist */
o->m_ptr = ziplistPush((unsigned char*)ptrFromObj(o), (unsigned char*)field,
@ -1663,9 +1671,17 @@ robj *rdbLoadObject(int rdbtype, rio *rdb, robj *key, uint64_t mvcc_tstamp) {
len--;
/* Load encoded strings */
if ((field = (sds)rdbGenericLoadStringObject(rdb,RDB_LOAD_SDS,NULL))
== NULL) return NULL;
== NULL)
{
decrRefCount(o);
return NULL;
}
if ((value = (sds)rdbGenericLoadStringObject(rdb,RDB_LOAD_SDS,NULL))
== NULL) return NULL;
== NULL)
{
decrRefCount(o);
return NULL;
}
/* Add pair to hash table */
ret = dictAdd((dict*)ptrFromObj(o), field, value);