fixed a few bugs in DS store, now it's somewhat about able to reply to 'GET foo'...

[redis.git] / src / t_set.c

diff --git a/src/t_set.c b/src/t_set.c
index 0b4128adf4c804053b9e237b0a7a9b9f354e8f1c..2af383d10f60a951de475247dffb8d66fdf67d10 100644 (file)
--- a/src/t_set.c
+++ b/src/t_set.c
@@ -231,7 +231,7 @@ void saddCommand(redisClient *c) {
         }
     }
     if (setTypeAdd(set,c->argv[2])) {
         }
     }
     if (setTypeAdd(set,c->argv[2])) {

-        touchWatchedKey(c->db,c->argv[1]);
+        signalModifiedKey(c->db,c->argv[1]);

         server.dirty++;
         addReply(c,shared.cone);
     } else {
         server.dirty++;
         addReply(c,shared.cone);
     } else {


@@ -248,7 +248,7 @@ void sremCommand(redisClient *c) {
     c->argv[2] = tryObjectEncoding(c->argv[2]);
     if (setTypeRemove(set,c->argv[2])) {
         if (setTypeSize(set) == 0) dbDelete(c->db,c->argv[1]);
     c->argv[2] = tryObjectEncoding(c->argv[2]);
     if (setTypeRemove(set,c->argv[2])) {
         if (setTypeSize(set) == 0) dbDelete(c->db,c->argv[1]);

-        touchWatchedKey(c->db,c->argv[1]);
+        signalModifiedKey(c->db,c->argv[1]);

         server.dirty++;
         addReply(c,shared.cone);
     } else {
         server.dirty++;
         addReply(c,shared.cone);
     } else {


@@ -287,8 +287,8 @@ void smoveCommand(redisClient *c) {
 
     /* Remove the src set from the database when empty */
     if (setTypeSize(srcset) == 0) dbDelete(c->db,c->argv[1]);
 
     /* Remove the src set from the database when empty */
     if (setTypeSize(srcset) == 0) dbDelete(c->db,c->argv[1]);

-    touchWatchedKey(c->db,c->argv[1]);
-    touchWatchedKey(c->db,c->argv[2]);
+    signalModifiedKey(c->db,c->argv[1]);
+    signalModifiedKey(c->db,c->argv[2]);

     server.dirty++;
 
     /* Create the destination set when it doesn't exist */
     server.dirty++;
 
     /* Create the destination set when it doesn't exist */


@@ -341,7 +341,7 @@ void spopCommand(redisClient *c) {
         setTypeRemove(set,ele);
     }
     if (setTypeSize(set) == 0) dbDelete(c->db,c->argv[1]);
         setTypeRemove(set,ele);
     }
     if (setTypeSize(set) == 0) dbDelete(c->db,c->argv[1]);

-    touchWatchedKey(c->db,c->argv[1]);
+    signalModifiedKey(c->db,c->argv[1]);

     server.dirty++;
 }
 
     server.dirty++;
 }
 


@@ -382,7 +382,7 @@ void sinterGenericCommand(redisClient *c, robj **setkeys, unsigned long setnum,
             zfree(sets);
             if (dstkey) {
                 if (dbDelete(c->db,dstkey)) {
             zfree(sets);
             if (dstkey) {
                 if (dbDelete(c->db,dstkey)) {

-                    touchWatchedKey(c->db,dstkey);
+                    signalModifiedKey(c->db,dstkey);

                     server.dirty++;
                 }
                 addReply(c,shared.czero);
                     server.dirty++;
                 }
                 addReply(c,shared.czero);


@@ -486,7 +486,7 @@ void sinterGenericCommand(redisClient *c, robj **setkeys, unsigned long setnum,
             decrRefCount(dstset);
             addReply(c,shared.czero);
         }
             decrRefCount(dstset);
             addReply(c,shared.czero);
         }

-        touchWatchedKey(c->db,dstkey);
+        signalModifiedKey(c->db,dstkey);

         server.dirty++;
     } else {
         setDeferredMultiBulkLength(c,replylen,cardinality);
         server.dirty++;
     } else {
         setDeferredMultiBulkLength(c,replylen,cardinality);


@@ -578,7 +578,7 @@ void sunionDiffGenericCommand(redisClient *c, robj **setkeys, int setnum, robj *
             decrRefCount(dstset);
             addReply(c,shared.czero);
         }
             decrRefCount(dstset);
             addReply(c,shared.czero);
         }

-        touchWatchedKey(c->db,dstkey);
+        signalModifiedKey(c->db,dstkey);

         server.dirty++;
     }
     zfree(sets);
         server.dirty++;
     }
     zfree(sets);