Fix gtidcheck (issue #5)

tanji · Feb 2, 2015 · 53e4874 · 53e4874
1 parent aed361a
commit 53e4874
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dbhelper/dbhelper.go b/dbhelper/dbhelper.go
@@ -357,7 +357,7 @@ func CheckSlaveSync(dbS *sqlx.DB, dbM *sqlx.DB) bool {
 		log.Printf("CheckSlaveSync called")
 	}
 	sGtid := GetVariableByName(dbS, "GTID_CURRENT_POS")
-	mGtid := GetVariableByName(dbM, "GTID_BINLOG_POS")
+	mGtid := GetVariableByName(dbM, "GTID_CURRENT_POS")
 	if sGtid == mGtid {
 		return true
 	} else {