Merge pull request #732 from signal18/topology

Fix master not refreshing after reconnect from suspect
signal18 · Jul 16, 2024 · 48ad128 · 48ad128
2 parents a8b0969 + b957174
commit 48ad128
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/cluster/cluster_topo.go b/cluster/cluster_topo.go
@@ -259,6 +259,12 @@ func (cluster *Cluster) TopologyDiscover(wcg *sync.WaitGroup) error {
 						cluster.master = cluster.Servers[k]
 						cluster.master.SetMaster()
 					}
+
+					// Set master when master reconnect after become suspect
+					if cluster.master == cluster.Servers[k] && cluster.master.State == stateSuspect {
+						cluster.master.SetMaster()
+					}
+
 					if cluster.master.IsReadOnly() && !cluster.master.IsRelay {
 						cluster.master.SetReadWrite()
 						cluster.LogModulePrintf(cluster.Conf.Verbose, config.ConstLogModTopology, config.LvlInfo, "Server %s disable read only as last non slave", cluster.master.URL)