rename masterchan to eventchan, retryNum -= 1 when error is retryable

hardcore-os · Feb 17, 2024 · 5af3cd5 · 5af3cd5
1 parent 1a5bc00
commit 5af3cd5
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/common/bizflow/graph.go b/common/bizflow/graph.go
@@ -119,7 +119,7 @@ func (g *Graph) execNext(it *item) {
 		}
 	}
 }
-func (g *Graph) masterChanClosed() bool {
+func (g *Graph) eventChanClosed() bool {
 	select {
 	case _, ok := <-g.eventChan:
 		return !ok
@@ -129,11 +129,11 @@ func (g *Graph) masterChanClosed() bool {
 }
 func (g *Graph) work(it *item) {
 	// 先检查一下
-	if g.masterChanClosed() {
+	if g.eventChanClosed() {
 		return
 	}
 	defer func() {
-		if !g.masterChanClosed() {
+		if !g.eventChanClosed() {
 			g.eventChan <- it
 		}
 	}()