From 252d7862f42009258877b574f6c8b3648a2fa9ee Mon Sep 17 00:00:00 2001
From: yedf2 <120050102@qq.com>
Date: Thu, 29 Jul 2021 00:29:49 +0800
Subject: [PATCH] change Chan test

---
 dtmsvr/cron.go  | 4 +++-
 dtmsvr/utils.go | 3 ---
 2 files changed, 3 insertions(+), 4 deletions(-)

diff --git a/dtmsvr/cron.go b/dtmsvr/cron.go
index 14600de..4318102 100644
--- a/dtmsvr/cron.go
+++ b/dtmsvr/cron.go
@@ -16,7 +16,9 @@ func CronTransOnce(expireIn time.Duration) bool {
 	if trans == nil {
 		return false
 	}
-	defer WaitTransProcessed(trans.Gid)
+	if TransProcessedTestChan != nil {
+		defer WaitTransProcessed(trans.Gid)
+	}
 	trans.Process(dbGet())
 	return true
 }
diff --git a/dtmsvr/utils.go b/dtmsvr/utils.go
index a552ba2..ad87dcd 100644
--- a/dtmsvr/utils.go
+++ b/dtmsvr/utils.go
@@ -38,9 +38,6 @@ var TransProcessedTestChan chan string = nil
 
 // WaitTransProcessed only for test usage. wait for transaction processed once
 func WaitTransProcessed(gid string) {
-	if TransProcessedTestChan == nil {
-		return
-	}
 	logrus.Printf("waiting for gid %s", gid)
 	id := <-TransProcessedTestChan
 	for id != gid {