diff --git a/src/replication.c b/src/replication.c index 00c3ad5fbd..590a4483de 100644 --- a/src/replication.c +++ b/src/replication.c @@ -2973,6 +2973,14 @@ static int dualChannelReplHandleHandshake(connection *conn, sds *err) { return C_ERR; } + if (server.replica_announce_ip) { + *err = sendCommand(conn, "REPLCONF", "ip-address", server.replica_announce_ip, NULL); + if (*err) { + dualChannelServerLog(LL_WARNING, "Sending command to primary in dual channel replication handshake: %s", *err); + return C_ERR; + } + } + if (connSetReadHandler(conn, dualChannelFullSyncWithPrimary) == C_ERR) { char conninfo[CONN_INFO_LEN]; dualChannelServerLog(LL_WARNING, "Can't create readable event for SYNC: %s (%s)", strerror(errno),