From 2a063792c3e7eae6a9878fdab07df500dc4ee815 Mon Sep 17 00:00:00 2001
From: liulei <liulei@xiaozhu.com>
Date: Fri, 7 Jan 2022 17:38:28 +0800
Subject: [PATCH] fix: change rollback err assert

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

diff --git a/dtmcli/barrier.go b/dtmcli/barrier.go
index 731f508..48e5ae3 100644
--- a/dtmcli/barrier.go
+++ b/dtmcli/barrier.go
@@ -67,12 +67,10 @@ 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 {
-			err := tx.Rollback()
-			dtmimp.E2P(err)
+			_ = tx.Rollback()
 			panic(x)
 		} else if rerr != nil {
-			err := tx.Rollback()
-			dtmimp.E2P(err)
+			_ = tx.Rollback()
 		} else {
 			rerr = tx.Commit()
 		}