Skip to content

Commit 4db74af

Browse files
committed
Fix delKeysInSlot does not consider command invoke.
Signed-off-by: wuranxx <[email protected]>
1 parent da2ab1a commit 4db74af

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

src/cluster_legacy.c

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6345,6 +6345,7 @@ unsigned int delKeysInSlot(unsigned int hashslot, int lazy) {
63456345
* state so that we don't assert in propagateNow(). */
63466346
server.server_del_keys_in_slot = 1;
63476347
unsigned int j = 0;
6348+
int before_execution_nesting = server.execution_nesting;
63486349

63496350
kvstoreHashtableIterator *kvs_di = NULL;
63506351
void *next;
@@ -6359,6 +6360,7 @@ unsigned int delKeysInSlot(unsigned int hashslot, int lazy) {
63596360
} else {
63606361
dbSyncDelete(&server.db[0], key);
63616362
}
6363+
dbDelete(&server.db[0], key);
63626364
propagateDeletion(&server.db[0], key, lazy);
63636365
signalModifiedKey(NULL, &server.db[0], key);
63646366
/* The keys are not actually logically deleted from the database, just moved to another node.
@@ -6374,7 +6376,7 @@ unsigned int delKeysInSlot(unsigned int hashslot, int lazy) {
63746376
kvstoreReleaseHashtableIterator(kvs_di);
63756377

63766378
server.server_del_keys_in_slot = 0;
6377-
serverAssert(server.execution_nesting == 0);
6379+
serverAssert(server.execution_nesting == before_execution_nesting);
63786380
return j;
63796381
}
63806382

0 commit comments

Comments
 (0)