forked from mirror/redis
Merge pull request #1065 from go-redis/fix/inc-stale-conns
Inc StaleConns in ReapStaleConns
This commit is contained in:
commit
8558c82c48
|
@ -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
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue