Skip to content
This repository has been archived by the owner on Nov 24, 2023. It is now read-only.

Commit

Permalink
revert clone change
Browse files Browse the repository at this point in the history
  • Loading branch information
GMHDBJD committed Dec 21, 2020
1 parent 10bcb7f commit ef4d21f
Showing 1 changed file with 2 additions and 4 deletions.
6 changes: 2 additions & 4 deletions relay/relay.go
Original file line number Diff line number Diff line change
Expand Up @@ -773,10 +773,8 @@ func (r *Relay) Status(ctx context.Context) interface{} {
rs.RelayBinlogGtid = relayGTIDSet.String()
}
if r.cfg.EnableGTID {
if masterGTID != nil && relayGTIDSet != nil {
if relayGTIDSet.Equal(masterGTID) {
rs.RelayCatchUpMaster = true
}
if masterGTID != nil && relayGTIDSet != nil && relayGTIDSet.Equal(masterGTID) {
rs.RelayCatchUpMaster = true
}
} else {
rs.RelayCatchUpMaster = masterPos.Compare(relayPos) == 0
Expand Down

0 comments on commit ef4d21f

Please sign in to comment.