Merge pull request #658 from signal18/semi-sync

semi-sync
signal18 · Jun 24, 2024 · d9f1f27 · d9f1f27
2 parents d9b58b3 + d29ba95
commit d9f1f27
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/cluster/srv_has.go b/cluster/srv_has.go
@@ -23,12 +23,14 @@ func (server *ServerMonitor) IsSemiSyncMaster() bool {
 }
 
 func (server *ServerMonitor) IsSemiSyncReplica() bool {
-	if server.DBVersion.IsMariaDB() || (server.DBVersion.IsMySQLOrPercona() && server.DBVersion.Lower("8.0")) {
+	// If MySQL or Percona 8.0 or greater
+	if server.DBVersion.IsMySQLOrPercona() && server.DBVersion.GreaterEqual("8.0") {
 		return server.Status["RPL_SEMI_SYNC_SLAVE_STATUS"] == "ON" || server.Status["RPL_SEMI_SYNC_REPLICA_STATUS"] == "ON"
 	}
-	if server.DBVersion.IsMySQLOrPercona() && server.DBVersion.GreaterEqual("8.0") {
-		return server.Status["RPL_SEMI_SYNC_SOURCE_STATUS"] == "ON" || server.Status["RPL_SEMI_SYNC_SOURCE_STATUS"] == "ON"
+	if server.DBVersion.IsMariaDB() || (server.DBVersion.IsMySQLOrPercona() && server.DBVersion.Lower("8.0")) {
+		return server.Status["RPL_SEMI_SYNC_SLAVE_STATUS"] == "ON"
 	}
+
 	return false
 }