From 3d54bc99be78c5337af597bfa584d063280f3925 Mon Sep 17 00:00:00 2001
From: HAOYUatHZ <haoyu@protonmail.com>
Date: Sun, 16 Jun 2019 09:54:54 +0800
Subject: [PATCH] ???

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

diff --git a/federation/warder.go b/federation/warder.go
index 631cd805..09609dd3 100644
--- a/federation/warder.go
+++ b/federation/warder.go
@@ -35,7 +35,7 @@ func NewWarder(cfg *config.Config, db *gorm.DB, txCh chan *orm.CrossTransaction)
 }
 
 func (w *warder) Run() {
-	go w.collectUnsubmittedTx()
+	go w.collectPendingTx()
 
 	for ormTx := range w.txCh {
 		if err := w.validateCrossTx(ormTx); err != nil {
@@ -97,7 +97,7 @@ func (w *warder) Run() {
 	}
 }
 
-func (w *warder) collectUnsubmittedTx() {
+func (w *warder) collectPendingTx() {
 	ticker := time.NewTicker(w.colletInterval)
 	for ; true; <-ticker.C {
 		txs := []*orm.CrossTransaction{}
@@ -108,7 +108,7 @@ func (w *warder) collectUnsubmittedTx() {
 			Find(&txs).Error; err == gorm.ErrRecordNotFound {
 			continue
 		} else if err != nil {
-			log.Warnln("collectUnsubmittedTx", err)
+			log.Warnln("collectPendingTx", err)
 		}
 
 		for _, tx := range txs {
-- 
2.11.0