diff --git a/src/cluster_migrateslots.c b/src/cluster_migrateslots.c index 380df3df3..6042ee43c 100644 --- a/src/cluster_migrateslots.c +++ b/src/cluster_migrateslots.c @@ -2557,6 +2557,13 @@ void clusterCommandSyncSlotsAck(client *c) { } } +void clusterCommandSyncSlotsCapa(client *c) { + UNUSED(c); + /* As of now there are no supported capa fields. We ignore unknown CAPA + * fields. */ + return; +} + /* Sent by either the target or the source as a control message for progressing * with slot import. */ void clusterCommandSyncSlots(client *c) { @@ -2604,6 +2611,11 @@ void clusterCommandSyncSlots(client *c) { clusterCommandSyncSlotsAck(c); return; } + if (!strcasecmp(c->argv[2]->ptr, "capa")) { + /* CLUSTER SYNCSLOTS CAPA [...] */ + clusterCommandSyncSlotsCapa(c); + return; + } if (c->slot_migration_job && isSlotMigrationJobInProgress(c->slot_migration_job)) { serverLog(LL_WARNING, "Received unknown SYNCSLOTS subcommand from "