Rewrite MIGRATE as DEL for AOF/replication. Also increment the dirty counter to both...

diff --git a/src/cluster.c b/src/cluster.c
index 2df3cfcf9a7845143feed32552e9a9459e0eab4b..78c28a0f450112fc19afcfceeb3cba53d253c7e4 100644 (file)
--- a/src/cluster.c
+++ b/src/cluster.c
@@ -1509,8 +1509,16 @@ void migrateCommand(redisClient *c) {
             addReplyErrorFormat(c,"Target instance replied with error: %s",
                 (buf1[0] == '-') ? buf1+1 : buf2+1);
         } else {
+            robj *aux;
+
             dbDelete(c->db,c->argv[3]);
             addReply(c,shared.ok);
+            server.dirty++;
+
+            /* Translate MIGRATE as DEL for replication/AOF. */
+            aux = createStringObject("DEL",2);
+            rewriteClientCommandVector(c,2,aux,c->argv[3]);
+            decrRefCount(aux);
         }
     }