Implement subkey expire for hashes
Former-commit-id: 8cbe254491826f2a461d504b6dabcbbab44d20b3
This commit is contained in:
parent
643a0e730f
commit
a9967659cd
@ -100,9 +100,19 @@ void activeExpireCycleExpire(redisDb *db, expireEntry &e, long long now) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
break;
|
break;
|
||||||
|
|
||||||
|
case OBJ_HASH:
|
||||||
|
if (hashTypeDelete(val,(sds)pfat->nextExpireEntry().spsubkey.get())) {
|
||||||
|
deleted++;
|
||||||
|
if (hashTypeLength(val) == 0) {
|
||||||
|
activeExpireCycleExpireFullKey(db, e.key());
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
|
||||||
case OBJ_LIST:
|
case OBJ_LIST:
|
||||||
case OBJ_ZSET:
|
case OBJ_ZSET:
|
||||||
case OBJ_HASH:
|
|
||||||
default:
|
default:
|
||||||
serverAssert(false);
|
serverAssert(false);
|
||||||
}
|
}
|
||||||
@ -170,6 +180,13 @@ void expireMemberCore(client *c, robj *key, robj *subkey, long long basetime, lo
|
|||||||
}
|
}
|
||||||
break;
|
break;
|
||||||
|
|
||||||
|
case OBJ_HASH:
|
||||||
|
if (!hashTypeExists(val, szFromObj(subkey))) {
|
||||||
|
addReply(c,shared.czero);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
|
||||||
default:
|
default:
|
||||||
addReplyError(c, "object type is unsupported");
|
addReplyError(c, "object type is unsupported");
|
||||||
return;
|
return;
|
||||||
|
Loading…
x
Reference in New Issue
Block a user