fix stuck in WaitForAllCommitted #1056

ffffwh · ffffwh · commit aaf94590f1ec · 2023-05-04T17:24:14.000+08:00
diff --git a/driver/mysql/applier_mts.go b/driver/mysql/applier_mts.go
@@ -62,7 +62,7 @@ func (mm *MtsManager) WaitForAllCommitted(logger g.LoggerType) bool {
 	defer t.Stop()
 
 	for {
-		if atomic.LoadInt64(&mm.lastCommitted) == mm.lastEnqueue {
+		if atomic.LoadInt64(&mm.lastCommitted) >= mm.lastEnqueue {
 			return true
 		}
 

Original file line number	Diff line number	Diff line change
`@@ -62,7 +62,7 @@ func (mm *MtsManager) WaitForAllCommitted(logger g.LoggerType) bool {`
`62`	`62`	`defer t.Stop()`
`63`	`63`
`64`	`64`	`for {`
`65`		`- if atomic.LoadInt64(&mm.lastCommitted) == mm.lastEnqueue {`
	`65`	`+ if atomic.LoadInt64(&mm.lastCommitted) >= mm.lastEnqueue {`
`66`	`66`	`return true`
`67`	`67`	`}`
`68`	`68`