From 8b2449dca092f532ca1fd90e41f9ba0f40c4166a Mon Sep 17 00:00:00 2001 From: Pieter Noordhuis Date: Tue, 22 Mar 2011 16:12:26 +0100 Subject: [PATCH] Backport patch: signalModifiedKey (unstable) -> touchWatchedKey (2.2) --- src/t_zset.c | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/src/t_zset.c b/src/t_zset.c index 1334572d37..ea91f8b5c4 100644 --- a/src/t_zset.c +++ b/src/t_zset.c @@ -859,7 +859,7 @@ void zaddGenericCommand(redisClient *c, int incr) { zobj->ptr = zzlDelete(zobj->ptr,eptr); zobj->ptr = zzlInsert(zobj->ptr,ele,score); - signalModifiedKey(c->db,key); + touchWatchedKey(c->db,key); server.dirty++; } @@ -876,7 +876,7 @@ void zaddGenericCommand(redisClient *c, int incr) { if (sdslen(ele->ptr) > server.zset_max_ziplist_value) zsetConvert(zobj,REDIS_ENCODING_RAW); - signalModifiedKey(c->db,key); + touchWatchedKey(c->db,key); server.dirty++; if (incr) /* ZINCRBY */ @@ -914,7 +914,7 @@ void zaddGenericCommand(redisClient *c, int incr) { incrRefCount(curobj); /* Re-inserted in skiplist. */ dictGetEntryVal(de) = &znode->score; /* Update score ptr. */ - signalModifiedKey(c->db,key); + touchWatchedKey(c->db,key); server.dirty++; } @@ -928,7 +928,7 @@ void zaddGenericCommand(redisClient *c, int incr) { redisAssert(dictAdd(zs->dict,ele,&znode->score) == DICT_OK); incrRefCount(ele); /* Added to dictionary. */ - signalModifiedKey(c->db,key); + touchWatchedKey(c->db,key); server.dirty++; if (incr) /* ZINCRBY */ @@ -990,7 +990,7 @@ void zremCommand(redisClient *c) { redisPanic("Unknown sorted set encoding"); } - signalModifiedKey(c->db,key); + touchWatchedKey(c->db,key); server.dirty++; addReply(c,shared.cone); } @@ -1022,7 +1022,7 @@ void zremrangebyscoreCommand(redisClient *c) { redisPanic("Unknown sorted set encoding"); } - if (deleted) signalModifiedKey(c->db,key); + if (deleted) touchWatchedKey(c->db,key); server.dirty += deleted; addReplyLongLong(c,deleted); } @@ -1070,7 +1070,7 @@ void zremrangebyrankCommand(redisClient *c) { redisPanic("Unknown sorted set encoding"); } - if (deleted) signalModifiedKey(c->db,key); + if (deleted) touchWatchedKey(c->db,key); server.dirty += deleted; addReplyLongLong(c,deleted); } @@ -1603,7 +1603,7 @@ void zunionInterGenericCommand(redisClient *c, robj *dstkey, int op) { dbAdd(c->db,dstkey,dstobj); addReplyLongLong(c,zsetLength(dstobj)); - if (!touched) signalModifiedKey(c->db,dstkey); + if (!touched) touchWatchedKey(c->db,dstkey); server.dirty++; } else { decrRefCount(dstobj);