From c9b8d2a1f0017edb4ef65c27a09293fdf584829a Mon Sep 17 00:00:00 2001
From: liulei <liulei@xiaozhu.com>
Date: Fri, 7 Jan 2022 17:22:10 +0800
Subject: [PATCH] fix: test trigger failed

---
 dtmcli/barrier.go | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/dtmcli/barrier.go b/dtmcli/barrier.go
index bc64940..731f508 100644
--- 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()
 		}