Skip to content

Commit 6bde139

Browse files
ranshidxbasel
authored andcommitted
fix expire propagation
Signed-off-by: Ran Shidlansik <[email protected]>
1 parent 9482444 commit 6bde139

2 files changed

Lines changed: 2 additions & 1 deletion

File tree

src/expire.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -547,7 +547,7 @@ int checkAlreadyExpired(long long when) {
547547
* - LT: set expiry only when the new expiry is less than current one */
548548
int parseExtendedExpireArgumentsOrReply(client *c, int *flags, int max_args) {
549549
int nx = 0, xx = 0, gt = 0, lt = 0;
550-
if (max_index < 0) max_index = c->argc - 1;
550+
if (max_index < 0) max_index = c->argc;
551551

552552
int j = 3;
553553
while (j < max_args) {

src/t_hash.c

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -252,6 +252,7 @@ int hashTypeExpireEntry(void *entry) {
252252
serverAssert(key);
253253
initStaticStringObject(keyobj, key);
254254
notifyKeyspaceEvent(NOTIFY_EXPIRED, "hexpired", &keyobj, server.access_context.db->id);
255+
serverLog(LL_NOTICE, "expiring entry %s of key %s", (sds)entry, key);
255256
hashTypePropagateDeletion(server.access_context.db, key, entry);
256257
return 1;
257258
}

0 commit comments

Comments
 (0)