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

common/bizflow/graph.go

@@ -90,6 +90,7 @@ func (g *Graph) Run(ctx context.Context) error {
 			g.tryStop(it)
 		case RetryableError:
 			if it.retryNum > 0 {
+				it.retryNum -= 1
 				g.e.workPool.Submit(func() { g.work(it) })
 			}
 		case NonRetryable:
@@ -118,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
@@ -128,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
 		}
 	}()