gvsafronov/futriix
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix memory leak in mvccRestore

Browse Source 
Former-commit-id: 165333b0fc648c79e66f04d9c8c4a1d0059fe57a
This commit is contained in:
John Sully 2021-02-07 23:38:09 +00:00
parent 651abfdca0
commit aa47e643b0
2 changed files with 10 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/Makefile
View File

@ -48,8 +48,8 @@ endif
USEASM?=true USEASM?=true
ifneq ($(strip $(SANITIZE)),) ifneq ($(strip $(SANITIZE)),)
CFLAGS+= -fsanitize=$(SANITIZE) -DSANITIZE CFLAGS+= -fsanitize=$(SANITIZE) -DSANITIZE -fno-omit-frame-pointer
CXXFLAGS+= -fsanitize=$(SANITIZE) -DSANITIZE CXXFLAGS+= -fsanitize=$(SANITIZE) -DSANITIZE -fno-omit-frame-pointer
LDFLAGS+= -fsanitize=$(SANITIZE) LDFLAGS+= -fsanitize=$(SANITIZE)
MALLOC=libc MALLOC=libc
USEASM=false USEASM=false

13
src/cluster.cpp
View File

@ -5066,12 +5066,15 @@ void mvccrestoreCommand(client *c) {
setMvccTstamp(obj, mvcc); setMvccTstamp(obj, mvcc);
/* Create the key and set the TTL if any */ /* Create the key and set the TTL if any */
dbMerge(c->db,key,obj,true); if (dbMerge(c->db,key,obj,true)) {
if (expire >= 0) { if (expire >= 0) {
setExpire(c,c->db,key,nullptr,expire); setExpire(c,c->db,key,nullptr,expire);
}
signalModifiedKey(c,c->db,key);
notifyKeyspaceEvent(NOTIFY_GENERIC,"restore",key,c->db->id);
} else {
decrRefCount(obj);
} }
signalModifiedKey(c,c->db,key);
notifyKeyspaceEvent(NOTIFY_GENERIC,"restore",key,c->db->id);
addReply(c,shared.ok); addReply(c,shared.ok);
g_pserver->dirty++; g_pserver->dirty++;
} }