summaryrefslogtreecommitdiff
path: root/src/t_set.c
diff options
context:
space:
mode:
authororanagra <oran@redislabs.com>2016-05-09 09:12:38 +0300
committeroranagra <oran@redislabs.com>2016-05-09 12:05:33 +0300
commit9682b616a21b5e675a1ca82109a11d6f4de1d2de (patch)
tree9f3c4cddb8b4877970d3f2252bb29ff5e6a326d6 /src/t_set.c
parent3b644e82b0cc96113e29672d1551248c9e9db893 (diff)
downloadredis-9682b616a21b5e675a1ca82109a11d6f4de1d2de.tar.gz
minor fixes - mainly signalModifiedKey, and GEORADIUS
Diffstat (limited to 'src/t_set.c')
-rw-r--r--src/t_set.c9
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) {