fix: test trigger failed

4 years ago · c9b8d2a1f0
1 changed files with 4 additions and 2 deletions
--- a/dtmcli/barrier.go
+++ b/dtmcli/barrier.go
@ -67,10 +67,12 @@ func (bb *BranchBarrier) Call(tx *sql.Tx, busiCall BarrierBusiFunc) (rerr error)
 	defer func() {
 		// Logf("barrier call error is %v", rerr)
 		if x := recover(); x != nil {
-			rerr = tx.Rollback()
+			err := tx.Rollback()
+			dtmimp.E2P(err)
 			panic(x)
 		} else if rerr != nil {
-			rerr = tx.Rollback()
+			err := tx.Rollback()
+			dtmimp.E2P(err)
 		} else {
 			rerr = tx.Commit()
 		}