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

Fix test failures: Non active replicas are allowed to use shared int values

Browse Source 
Former-commit-id: 8536854266d5795c5c2bc11b8b344f20759b55af
This commit is contained in:
John Sully 2019-07-30 17:11:15 -04:00
parent 863ae63e2c
commit 02151b9110
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/db.cpp
View File

@ -269,7 +269,7 @@ void dbOverwrite(redisDb *db, robj *key, robj *val) {
dictEntry *de = dictFind(db->pdict,ptrFromObj(key)); dictEntry *de = dictFind(db->pdict,ptrFromObj(key));
serverAssertWithInfo(NULL,key,de != NULL); serverAssertWithInfo(NULL,key,de != NULL);
dbOverwriteCore(db, de, key, val, true, false); dbOverwriteCore(db, de, key, val, !!g_pserver->fActiveReplica, false);
} }
/* Insert a key, handling duplicate keys according to fReplace */ /* Insert a key, handling duplicate keys according to fReplace */
@ -309,7 +309,7 @@ void setKey(redisDb *db, robj *key, robj *val) {
if (de == NULL) { if (de == NULL) {
dbAdd(db,key,val); dbAdd(db,key,val);
} else { } else {
dbOverwriteCore(db,de,key,val,true,true); dbOverwriteCore(db,de,key,val,!!g_pserver->fActiveReplica,true);
} }
incrRefCount(val); incrRefCount(val);
signalModifiedKey(db,key); signalModifiedKey(db,key);