fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-04-10 11:16:06 +00:00
Code Issues Projects Releases Wiki Activity

allow to set a new EXPIRE of an existing volatile key

Browse Source
This commit is contained in:
antirez 2010-08-03 12:26:30 +02:00
parent c25a5d3b10
commit 0cf5b7b57c
2 changed files with 9 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/db.c
View File

@ -401,16 +401,13 @@ int removeExpire(redisDb *db, robj *key) {
} }
} }
int setExpire(redisDb *db, robj *key, time_t when) { void setExpire(redisDb *db, robj *key, time_t when) {
dictEntry *de; dictEntry *de;
/* Reuse the sds from the main dict in the expire dict */ /* Reuse the sds from the main dict in the expire dict */
redisAssert((de = dictFind(db->dict,key->ptr)) != NULL); de = dictFind(db->dict,key->ptr);
if (dictAdd(db->expires,dictGetEntryKey(de),(void*)when) == DICT_ERR) { redisAssert(de != NULL);
return 0; dictReplace(db->expires,dictGetEntryKey(de),(void*)when);
} else {
return 1;
}
} }
/* Return the expire time of the specified key, or -1 if no expire /* Return the expire time of the specified key, or -1 if no expire
@ -504,13 +501,10 @@ void expireGenericCommand(redisClient *c, robj *key, robj *param, long offset) {
return; return;
} else { } else {
time_t when = time(NULL)+seconds; time_t when = time(NULL)+seconds;
if (setExpire(c->db,key,when)) { setExpire(c->db,key,when);
addReply(c,shared.cone); addReply(c,shared.cone);
touchWatchedKey(c->db,key); touchWatchedKey(c->db,key);
server.dirty++; server.dirty++;
} else {
addReply(c,shared.czero);
}
return; return;
} }
} }

2
src/redis.h
View File

@ -755,7 +755,7 @@ int removeExpire(redisDb *db, robj *key);
void propagateExpire(redisDb *db, robj *key); void propagateExpire(redisDb *db, robj *key);
int expireIfNeeded(redisDb *db, robj *key); int expireIfNeeded(redisDb *db, robj *key);
time_t getExpire(redisDb *db, robj *key); time_t getExpire(redisDb *db, robj *key);
int setExpire(redisDb *db, robj *key, time_t when); void setExpire(redisDb *db, robj *key, time_t when);
robj *lookupKey(redisDb *db, robj *key); robj *lookupKey(redisDb *db, robj *key);
robj *lookupKeyRead(redisDb *db, robj *key); robj *lookupKeyRead(redisDb *db, robj *key);
robj *lookupKeyWrite(redisDb *db, robj *key); robj *lookupKeyWrite(redisDb *db, robj *key);