fix queueMaxSpanFlowControlTimes not change

cserwen · cserwen · commit 449e940d9461 · 2022-05-07T16:58:23.000+08:00
diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
@@ -623,6 +623,7 @@ func (pc *pushConsumer) pullMessage(request *PullRequest) {
 						rlog.LogKeyPullRequest:       request.String(),
 					})
 				}
+				pc.queueMaxSpanFlowControlTimes++
 				sleepTime = _PullDelayTimeWhenFlowControl
 				goto NEXT
 			}

Original file line number	Diff line number	Diff line change
`@@ -623,6 +623,7 @@ func (pc pushConsumer) pullMessage(request PullRequest) {`
`623`	`623`	`rlog.LogKeyPullRequest: request.String(),`
`624`	`624`	`})`
`625`	`625`	`}`
	`626`	`+ pc.queueMaxSpanFlowControlTimes++`
`626`	`627`	`sleepTime = _PullDelayTimeWhenFlowControl`
`627`	`628`	`goto NEXT`
`628`	`629`	`}`