mirror of
https://github.com/redis/go-redis.git
synced 2025-07-25 08:21:55 +03:00
Inc StaleConns in ReapStaleConns
This commit is contained in:
@ -428,12 +428,11 @@ func (p *ConnPool) reaper(frequency time.Duration) {
|
||||
if p.closed() {
|
||||
break
|
||||
}
|
||||
n, err := p.ReapStaleConns()
|
||||
_, err := p.ReapStaleConns()
|
||||
if err != nil {
|
||||
internal.Logger.Printf("ReapStaleConns failed: %s", err)
|
||||
continue
|
||||
}
|
||||
atomic.AddUint32(&p.stats.StaleConns, uint32(n))
|
||||
}
|
||||
}
|
||||
|
||||
@ -454,6 +453,7 @@ func (p *ConnPool) ReapStaleConns() (int, error) {
|
||||
break
|
||||
}
|
||||
}
|
||||
atomic.AddUint32(&p.stats.StaleConns, uint32(n))
|
||||
return n, nil
|
||||
}
|
||||
|
||||
|
Reference in New Issue
Block a user