diff --git a/src/server.h b/src/server.h index 29cbdc5c65..8f4fb6a6b4 100644 --- a/src/server.h +++ b/src/server.h @@ -3915,7 +3915,7 @@ void debugPauseProcess(void); /* dualChannelServerLog - Log messages related to dual-channel operations * This macro wraps the serverLog function, prepending "" * to the log message. */ -#define dualChannelServerLog(level, ...) serverLog(level, " " __VA_ARGS__) +#define dualChannelServerLog(level, ...) serverLog(level, "Dual channel replication: " __VA_ARGS__) #define serverDebug(fmt, ...) printf("DEBUG %s:%d > " fmt "\n", __FILE__, __LINE__, __VA_ARGS__) #define serverDebugMark() printf("-- MARK %s:%d --\n", __FILE__, __LINE__) diff --git a/tests/integration/dual-channel-replication.tcl b/tests/integration/dual-channel-replication.tcl index ec6783c1c9..dc0de5a734 100644 --- a/tests/integration/dual-channel-replication.tcl +++ b/tests/integration/dual-channel-replication.tcl @@ -487,7 +487,7 @@ start_server {tags {"dual-channel-replication external:skip"}} { } wait_for_value_to_propagate_to_replica $primary $replica "key1" # Confirm the occurrence of a race condition. - wait_for_log_messages -1 {"* Psync established after rdb load*"} 0 2000 1 + wait_for_log_messages -1 {"*Dual channel replication: Psync established after rdb load*"} 0 2000 1 } } }