diff --git a/src/cluster.c b/src/cluster.c index fd295df3..36e6c525 100644 --- a/src/cluster.c +++ b/src/cluster.c @@ -4763,8 +4763,6 @@ try_again: } } else { if (!copy) { - robj *aux; - /* No COPY option: remove the local key, signal the change. */ dbDelete(c->db,kv[j]); signalModifiedKey(c->db,kv[j]); @@ -4772,6 +4770,7 @@ try_again: /* Populate the argument vector to replace the old one. */ newargv[del_idx++] = kv[j]; + incrRefCount(kv[j]); } } } @@ -4780,7 +4779,7 @@ try_again: /* Translate MIGRATE as DEL for replication/AOF. */ if (del_idx > 1) { newargv[0] = createStringObject("DEL",3); - replaceClientCommandVector(c,newargv,del_idx); + replaceClientCommandVector(c,del_idx,newargv); } else { /* No key transfer acknowledged, no need to rewrite as DEL. */ zfree(newargv);