diff options
| -rw-r--r-- | src/t_string.c | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/src/t_string.c b/src/t_string.c index 7b67b78ce..9d7bc44fc 100644 --- a/src/t_string.c +++ b/src/t_string.c @@ -411,12 +411,9 @@ void getexCommand(client *c) { void getdelCommand(client *c) { if (getGenericCommand(c) == C_ERR) return; - int deleted = server.lazyfree_lazy_user_del ? dbAsyncDelete(c->db, c->argv[1]) : - dbSyncDelete(c->db, c->argv[1]); - if (deleted) { - /* Propagate as DEL/UNLINK command */ - robj *aux = server.lazyfree_lazy_user_del ? shared.unlink : shared.del; - rewriteClientCommandVector(c,2,aux,c->argv[1]); + if (dbSyncDelete(c->db, c->argv[1])) { + /* Propagate as DEL command */ + rewriteClientCommandVector(c,2,shared.del,c->argv[1]); signalModifiedKey(c, c->db, c->argv[1]); notifyKeyspaceEvent(NOTIFY_GENERIC, "del", c->argv[1], c->db->id); server.dirty++; |