forked from mirror/redis
chore: fix build
This commit is contained in:
parent
0aa94538ee
commit
a15a89ea58
|
@ -542,7 +542,7 @@ func (p *ConnPool) reapStaleConn() *Conn {
|
||||||
|
|
||||||
func (p *ConnPool) isStaleConn(cn *Conn) bool {
|
func (p *ConnPool) isStaleConn(cn *Conn) bool {
|
||||||
if p.opt.IdleTimeout == 0 && p.opt.MaxConnAge == 0 {
|
if p.opt.IdleTimeout == 0 && p.opt.MaxConnAge == 0 {
|
||||||
return false
|
return connCheck(cn.netConn) != nil
|
||||||
}
|
}
|
||||||
|
|
||||||
now := time.Now()
|
now := time.Now()
|
||||||
|
@ -553,5 +553,5 @@ func (p *ConnPool) isStaleConn(cn *Conn) bool {
|
||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
|
|
||||||
return false
|
return connCheck(cn.netConn) != nil
|
||||||
}
|
}
|
||||||
|
|
|
@ -324,7 +324,7 @@ func startRedis(port string, args ...string) (*redisProcess, error) {
|
||||||
|
|
||||||
p := &redisProcess{process, client}
|
p := &redisProcess{process, client}
|
||||||
registerProcess(port, p)
|
registerProcess(port, p)
|
||||||
return p, err
|
return p, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func startSentinel(port, masterName, masterPort string) (*redisProcess, error) {
|
func startSentinel(port, masterName, masterPort string) (*redisProcess, error) {
|
||||||
|
|
Loading…
Reference in New Issue