From a0d4c00da609865654b2f24ae551b092e04161fa Mon Sep 17 00:00:00 2001
From: yedf2 <120050102@qq.com>
Date: Fri, 7 Jan 2022 08:16:51 +0800
Subject: [PATCH] barrier use if err == nil

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

diff --git a/dtmcli/barrier.go b/dtmcli/barrier.go
index 5cffeba..c502742 100644
--- a/dtmcli/barrier.go
+++ b/dtmcli/barrier.go
@@ -95,10 +95,10 @@ func (bb *BranchBarrier) Call(tx *sql.Tx, busiCall BarrierBusiFunc) (rerr error)
 // CallWithDB the same as Call, but with *sql.DB
 func (bb *BranchBarrier) CallWithDB(db *sql.DB, busiCall BarrierBusiFunc) error {
 	tx, err := db.Begin()
-	if err != nil {
-		return err
+	if err == nil {
+		err = bb.Call(tx, busiCall)
 	}
-	return bb.Call(tx, busiCall)
+	return err
 }
 
 func (bb *BranchBarrier) QueryPrepared(db *sql.DB) error {