Fix memory leak
This commit is contained in:
1 parent
8b24244447
commit
0d64f32ca1
1 file changed
+4
@@ -2976,6 +2976,8 @@ bool redisDbPersistentData::processChanges(bool fSnapshot)
|
||||
}
|
||||
}
|
||||
m_spstorage->bulkInsert(veckeys.data(), veccbkeys.data(), vecvals.data(), veccbvals.data(), vecoverwrite.data(), veckeys.size());
|
||||
for (auto val : vecvals)
|
||||
sdsfree(val);
|
||||
dictReleaseIterator(di);
|
||||
}
|
||||
}
|
||||
@@ -3051,6 +3053,8 @@ void redisDbPersistentData::commitChanges(const redisDbPersistentDataSnapshot **
|
||||
}
|
||||
}
|
||||
m_spstorage->bulkInsert(veckeys.data(), veccbkeys.data(), vecvals.data(), veccbvals.data(), vecoverwrite.data(), veckeys.size());
|
||||
for (auto val : vecvals)
|
||||
sdsfree(val);
|
||||
dictReleaseIterator(di);
|
||||
dictRelease(m_dictChangedStorageFlush);
|
||||
m_dictChangedStorageFlush = nullptr;
|
||||
|
||||
Reference in new issue
Block a user