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 {