diff --git a/src/server.cc b/src/server.cc index 2a5ca3aa390..a309076fa03 100644 --- a/src/server.cc +++ b/src/server.cc @@ -693,6 +693,7 @@ void Server::GetReplicationInfo(std::string *info) { ++idx; } slave_threads_mu_.unlock(); + string_stream << "master_repl_offset:" << latest_seq << "\r\n"; *info = string_stream.str(); } diff --git a/tests/tcl/tests/support/util.tcl b/tests/tcl/tests/support/util.tcl index 821219a6479..0b421aec8a2 100644 --- a/tests/tcl/tests/support/util.tcl +++ b/tests/tcl/tests/support/util.tcl @@ -95,7 +95,7 @@ proc wait_for_sync r { proc wait_for_ofs_sync {r1 r2} { wait_for_condition 50 100 { - [status $r1 sequence] eq [status $r2 sequence] + [status $r1 master_repl_offset] eq [status $r2 master_repl_offset] } else { fail "replica didn't sync in time" }