diff options
author | oranagra <oran@redislabs.com> | 2016-05-09 09:12:38 +0300 |
---|---|---|
committer | oranagra <oran@redislabs.com> | 2016-05-09 12:05:33 +0300 |
commit | 9682b616a21b5e675a1ca82109a11d6f4de1d2de (patch) | |
tree | 9f3c4cddb8b4877970d3f2252bb29ff5e6a326d6 /src/t_set.c | |
parent | 3b644e82b0cc96113e29672d1551248c9e9db893 (diff) | |
download | redis-9682b616a21b5e675a1ca82109a11d6f4de1d2de.tar.gz |
minor fixes - mainly signalModifiedKey, and GEORADIUS
Diffstat (limited to 'src/t_set.c')
-rw-r--r-- | src/t_set.c | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/src/t_set.c b/src/t_set.c index 7a2a77ff6..db5c544b6 100644 --- a/src/t_set.c +++ b/src/t_set.c @@ -351,9 +351,6 @@ void smoveCommand(client *c) { dbDelete(c->db,c->argv[1]); notifyKeyspaceEvent(NOTIFY_GENERIC,"del",c->argv[1],c->db->id); } - signalModifiedKey(c->db,c->argv[1]); - signalModifiedKey(c->db,c->argv[2]); - server.dirty++; /* Create the destination set when it doesn't exist */ if (!dstset) { @@ -361,6 +358,10 @@ void smoveCommand(client *c) { dbAdd(c->db,c->argv[2],dstset); } + signalModifiedKey(c->db,c->argv[1]); + signalModifiedKey(c->db,c->argv[2]); + server.dirty++; + /* An extra key has changed when ele was successfully added to dstset */ if (setTypeAdd(dstset,ele->ptr)) { server.dirty++; @@ -547,6 +548,8 @@ void spopWithCountCommand(client *c) { * the alsoPropagate() API. */ decrRefCount(propargv[0]); preventCommandPropagation(c); + signalModifiedKey(c->db,c->argv[1]); + server.dirty++; } void spopCommand(client *c) { |