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

charles-chenzz · charles-chenzz · commit 5af3cd546cea · 2024-02-17T11:40:55.000+08:00
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
 		}
 	}()

Original file line number	Diff line number	Diff line change
`@@ -119,7 +119,7 @@ func (g Graph) execNext(it item) {`
`119`	`119`	`}`
`120`	`120`	`}`
`121`	`121`	`}`
`122`		`-func (g *Graph) masterChanClosed() bool {`
	`122`	`+func (g *Graph) eventChanClosed() bool {`
`123`	`123`	`select {`
`124`	`124`	`case _, ok := <-g.eventChan:`
`125`	`125`	`return !ok`
`@@ -129,11 +129,11 @@ func (g *Graph) masterChanClosed() bool {`
`129`	`129`	`}`
`130`	`130`	`func (g Graph) work(it item) {`
`131`	`131`	`// 先检查一下`
`132`		`- if g.masterChanClosed() {`
	`132`	`+ if g.eventChanClosed() {`
`133`	`133`	`return`
`134`	`134`	`}`
`135`	`135`	`defer func() {`
`136`		`- if !g.masterChanClosed() {`
	`136`	`+ if !g.eventChanClosed() {`
`137`	`137`	`g.eventChan <- it`
`138`	`138`	`}`
`139`	`139`	`}()`