From dfc033ae4f5c22343b4aca25eaa57d79d605e6a4 Mon Sep 17 00:00:00 2001 From: yedf2 <120050102@qq.com> Date: Sat, 25 Sep 2021 23:17:19 +0800 Subject: [PATCH] fix process no return error --- dtmsvr/trans.go | 1 + 1 file changed, 1 insertion(+) diff --git a/dtmsvr/trans.go b/dtmsvr/trans.go index f1da4f5..d2cf575 100644 --- a/dtmsvr/trans.go +++ b/dtmsvr/trans.go @@ -120,6 +120,7 @@ func (t *TransGlobal) getProcessor() transProcessor { func (t *TransGlobal) Process(db *common.DB, waitResult bool) dtmcli.M { r := t.process(db, waitResult) transactionMetrics(t, r["dtm_result"] == dtmcli.ResultSuccess) + return r } func (t *TransGlobal) process(db *common.DB, waitResult bool) dtmcli.M {