mirror
/
redis
mirror of https://github.com/go-redis/redis.git
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1494 from go-redis/fix/do-not-use-retry-backoff 

Do not use retry backoff in PubSub
This commit is contained in:
Vladimir Mihailenco 2020-09-17 13:08:17 +03:00 committed by GitHub
parent 6a1b941a69 76f1e50d50
commit 8f33c7c6b0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pubsub.go
View File

@ -528,7 +528,7 @@ func (c *PubSub) initMsgChan(size int) {
return return
} }
if errCount > 0 { if errCount > 0 {
time.Sleep(c.retryBackoff(errCount)) time.Sleep(100 * time.Millisecond)
} }
errCount++ errCount++
continue continue
@ -586,7 +586,7 @@ func (c *PubSub) initAllChan(size int) {
return return
} }
if errCount > 0 { if errCount > 0 {
time.Sleep(c.retryBackoff(errCount)) time.Sleep(100 * time.Millisecond)
} }
errCount++ errCount++
continue continue
@ -627,7 +627,3 @@ func (c *PubSub) sendMessage(msg interface{}, timer *time.Timer) {
"redis: %s channel is full for %s (message is dropped)", c, pingTimeout) "redis: %s channel is full for %s (message is dropped)", c, pingTimeout)
} }
} }
func (c *PubSub) retryBackoff(attempt int) time.Duration {
return internal.RetryBackoff(attempt, c.opt.MinRetryBackoff, c.opt.MaxRetryBackoff)
}