Home
last modified time | relevance | path

Searched refs:backoffCounter (Results 1 – 1 of 1) sorted by relevance

/dports/net/nsq/nsq-1.2.1/vendor/github.com/nsqio/go-nsq/
H A Dconsumer.go93 backoffCounter int32 member
786 backoffCounter := atomic.LoadInt32(&r.backoffCounter)
789 if backoffCounter > 0 {
790 backoffCounter--
794 nextBackoff := r.config.BackoffStrategy.Calculate(int(backoffCounter) + 1)
796 backoffCounter++
800 atomic.StoreInt32(&r.backoffCounter, backoffCounter)
802 if r.backoffCounter == 0 && backoffUpdated {
809 } else if r.backoffCounter > 0 {
818 backoffDuration, backoffCounter)
[all …]